public class PojoCodec extends AbstractCodec<T>
Modifier and Type | Field and Description |
---|---|
protected static int |
FILE_REGISTRATION_ID |
protected com.esotericsoftware.kryo.pool.KryoPool |
pool |
protected static int |
TUPLE_REGISTRATION_ID |
Constructor and Description |
---|
PojoCodec() |
Modifier and Type | Method and Description |
---|---|
protected void |
configureKryoInstance(com.esotericsoftware.kryo.Kryo kryo) |
T |
deserialize(byte[] bytes)
Deserialize an object when the type is known
|
T |
deserialize(byte[] bytes,
java.lang.Class<? extends T> type)
Deserialize an object of a given type
|
T |
deserialize(java.io.InputStream inputStream)
Deserialize an object when the type is known
|
T |
deserialize(java.io.InputStream inputStream,
java.lang.Class<? extends T> type)
Deserialize an object of a given type
|
protected T |
doDeserialize(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input)
Infers the type from this class's generic type argument
|
protected java.lang.Object |
doDeserialize(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input,
java.lang.Class<? extends java.lang.Object> type) |
protected void |
doSerialize(com.esotericsoftware.kryo.Kryo kryo,
java.lang.Object object,
com.esotericsoftware.kryo.io.Output output) |
void |
serialize(T object,
java.io.OutputStream outputStream)
Serialize an object using an existing output stream
|
protected static final int FILE_REGISTRATION_ID
protected static final int TUPLE_REGISTRATION_ID
protected final com.esotericsoftware.kryo.pool.KryoPool pool
protected void doSerialize(com.esotericsoftware.kryo.Kryo kryo, java.lang.Object object, com.esotericsoftware.kryo.io.Output output)
protected java.lang.Object doDeserialize(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, java.lang.Class<? extends java.lang.Object> type)
public T deserialize(byte[] bytes, java.lang.Class<? extends T> type) throws java.io.IOException
deserialize
in interface MultiTypeCodec<T>
bytes
- the byte array containing the serialized objecttype
- the object's classjava.io.IOException
public T deserialize(java.io.InputStream inputStream, java.lang.Class<? extends T> type) throws java.io.IOException
MultiTypeCodec
deserialize
in interface MultiTypeCodec<T>
inputStream
- the input stream containing the serialized objecttype
- the object's classjava.io.IOException
protected T doDeserialize(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input)
kryo
- input
- public void serialize(T object, java.io.OutputStream outputStream) throws java.io.IOException
object
- the object to be serializedoutputStream
- the output stream, e.g. a FileOutputStreamjava.io.IOException
public T deserialize(java.io.InputStream inputStream) throws java.io.IOException
inputStream
- the input stream containing the serialized objectjava.io.IOException
public T deserialize(byte[] bytes) throws java.io.IOException
deserialize
in class AbstractCodec<T>
bytes
- the byte array containing the serialized objectjava.io.IOException
protected void configureKryoInstance(com.esotericsoftware.kryo.Kryo kryo)