public abstract class AbstractKryoCodec<T> extends AbstractCodec<T>
Kryo| Modifier and Type | Field and Description |
|---|---|
protected static int |
ARRAY_LIST_REGISTRATION_ID |
protected static int |
FILE_REGISTRATION_ID |
protected static int |
LONG_REGISTRATION_ID |
protected com.esotericsoftware.kryo.pool.KryoPool |
pool |
protected static int |
TUPLE_REGISTRATION_ID |
protected static int |
UUID_REGISTRATION_ID |
| Modifier | Constructor and Description |
|---|---|
protected |
AbstractKryoCodec() |
| 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(java.io.InputStream inputStream)
Deserialize an object when the type is known
|
protected abstract T |
doDeserialize(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input) |
protected abstract void |
doSerialize(com.esotericsoftware.kryo.Kryo kryo,
T 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 static final int ARRAY_LIST_REGISTRATION_ID
protected static final int UUID_REGISTRATION_ID
protected static final int LONG_REGISTRATION_ID
protected final com.esotericsoftware.kryo.pool.KryoPool pool
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.IOExceptionpublic T deserialize(java.io.InputStream inputStream) throws java.io.IOException
inputStream - the input stream containing the serialized objectjava.io.IOExceptionpublic T deserialize(byte[] bytes) throws java.io.IOException
deserialize in class AbstractCodec<T>bytes - the byte array containing the serialized objectjava.io.IOExceptionprotected abstract void doSerialize(com.esotericsoftware.kryo.Kryo kryo,
T object,
com.esotericsoftware.kryo.io.Output output)
protected abstract T doDeserialize(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input)
protected void configureKryoInstance(com.esotericsoftware.kryo.Kryo kryo)