Class WindowKryoSerializer
java.lang.Object
org.apache.storm.trident.windowing.WindowKryoSerializer
Kryo serializer/deserializer for values that are stored as part of windowing. This can be used in
WindowsStore. This class is not
thread safe.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiondeserialize(byte[] buff) Returns an Object which is created using Kryo deserialization of given byte array instance.deserialize(ByteBuffer byteBuffer) Returns an Object which is created using Kryo deserialization of givenbyteBufferinstance.byte[]Serializes the given object into a byte array using Kryo serialization.Serializes the given object into aByteBufferbacked by the byte array returned by Kryo serialization.
-
Constructor Details
-
WindowKryoSerializer
-
-
Method Details
-
serialize
Serializes the given object into a byte array using Kryo serialization.- Parameters:
obj- Object to be serialized.
-
serializeToByteBuffer
Serializes the given object into aByteBufferbacked by the byte array returned by Kryo serialization.- Parameters:
obj- Object to be serialized.
-
deserialize
Returns an Object which is created using Kryo deserialization of given byte array instance.- Parameters:
buff- byte array to be deserialized into an Object
-
deserialize
Returns an Object which is created using Kryo deserialization of givenbyteBufferinstance.- Parameters:
byteBuffer- byte buffer to be deserialized into an Object
-