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 Summary
Modifier and TypeFieldDescriptionstatic final String
The secret key (if any) for data encryption by blowfish payload serialization factory (BlowfishSerializationFactory). -
Constructor Summary
ConstructorDescriptionBlowfishTupleSerializer
(com.esotericsoftware.kryo.Kryo unused, Map<String, Object> topoConf) -
Method Summary
Modifier and TypeMethodDescriptionstatic void
Produce 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) void
write
(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, ListDelegate object) Methods inherited from class com.esotericsoftware.kryo.Serializer
copy, getAcceptsNull, isImmutable, setAcceptsNull, setImmutable
-
Field Details
-
SECRET_KEY
The 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
-
main
Produce a blowfish key to be used in "Storm jar" command. -
write
public void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, ListDelegate object) - Specified by:
write
in classcom.esotericsoftware.kryo.Serializer<ListDelegate>
-
read
public ListDelegate read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends ListDelegate> type) - Specified by:
read
in classcom.esotericsoftware.kryo.Serializer<ListDelegate>
-