Class BlowfishTupleSerializer
java.lang.Object
com.esotericsoftware.kryo.Serializer<ListDelegate>
org.apache.storm.security.serialization.BlowfishTupleSerializer
Apply Blowfish encryption for tuple communication to bolts.
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final StringThe secret key (if any) for data encryption by blowfish payload serialization factory (BlowfishSerializationFactory).
- 
Constructor SummaryConstructorsConstructorDescriptionBlowfishTupleSerializer(com.esotericsoftware.kryo.Kryo unused, Map<String, Object> topoConf) 
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidProduce a blowfish key to be used in "Storm jar" command.read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends ListDelegate> type) voidwrite(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, ListDelegate object) Methods inherited from class com.esotericsoftware.kryo.Serializercopy, getAcceptsNull, isImmutable, setAcceptsNull, setImmutable
- 
Field Details- 
SECRET_KEYThe secret key (if any) for data encryption by blowfish payload serialization factory (BlowfishSerializationFactory). You should use in via:```storm -c topology.tuple.serializer.blowfish.key=YOURKEY -c topology.tuple.serializer=org.apache.storm.security.serialization .BlowfishTupleSerializer jar ...``` - See Also:
 
 
- 
- 
Constructor Details- 
BlowfishTupleSerializer
 
- 
- 
Method Details- 
mainProduce a blowfish key to be used in "Storm jar" command.
- 
writepublic void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, ListDelegate object) - Specified by:
- writein class- com.esotericsoftware.kryo.Serializer<ListDelegate>
 
- 
readpublic ListDelegate read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends ListDelegate> type) - Specified by:
- readin class- com.esotericsoftware.kryo.Serializer<ListDelegate>
 
 
-