org.apache.s4.comm.serialize
Class KryoSerDeser
java.lang.Object
org.apache.s4.comm.serialize.KryoSerDeser
- All Implemented Interfaces:
- SerializerDeserializer
public class KryoSerDeser
- extends java.lang.Object
- implements SerializerDeserializer
Serializazer/deserializer based on kryo
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
KryoSerDeser
public KryoSerDeser()
KryoSerDeser
public KryoSerDeser(java.lang.ClassLoader classLoader)
- Parameters:
classLoader
- classloader able to handle classes to serialize/deserialize. For instance, application-level events
can only be handled by the application classloader.
setInitialBufferSize
public void setInitialBufferSize(int initialBufferSize)
setMaxBufferSize
public void setMaxBufferSize(int maxBufferSize)
deserialize
public java.lang.Object deserialize(byte[] rawMessage)
- Specified by:
deserialize
in interface SerializerDeserializer
serialize
public byte[] serialize(java.lang.Object message)
- Specified by:
serialize
in interface SerializerDeserializer