de.ipcon.db.io

Class SchemaAwareKryo

java.lang.Object

com.esotericsoftware.kryo.Kryo

de.ipcon.db.io.SchemaAwareKryo

public class SchemaAwareKryo
extends com.esotericsoftware.kryo.Kryo

Field Summary

Fields inherited from class com.esotericsoftware.kryo.Kryo

NOT_NULL, NULL

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush()
static SchemaAwareKryo	forInput(SchemaI schema, java.io.InputStream is)
static SchemaAwareKryo	forOutput(SchemaI schema, java.io.OutputStream os, boolean asServer)
java.io.InputStream	getCommonInputStream()
java.io.OutputStream	getCommonOutputStream()
com.esotericsoftware.kryo.Serializer	getDefaultSerializer(java.lang.Class type)
java.lang.Object	readClassAndObject()
void	setReplaceBoAfterRead(java.util.function.Function<Identifiable,Identifiable> replaceFunction)
void	setReplaceBoBeforeWrite(java.util.function.Function<Identifiable,Identifiable> replaceFunction)
void	writeClassAndObject(java.lang.Object o)
void	writeClassAndObject(com.esotericsoftware.kryo.io.Output output, java.lang.Object o)

Methods inherited from class com.esotericsoftware.kryo.Kryo

addDefaultSerializer, addDefaultSerializer, addDefaultSerializer, copy, copy, copyShallow, copyShallow, getClassLoader, getClassResolver, getContext, getDepth, getGenerics, getGraphContext, getInstantiatorStrategy, getNextRegistrationId, getOriginalToCopyMap, getReferenceResolver, getReferences, getRegistration, getRegistration, getSerializer, getWarnUnregisteredClasses, isClosure, isFinal, isRegistrationRequired, newInstance, readClass, readClassAndObject, readObject, readObject, readObjectOrNull, readObjectOrNull, reference, register, register, register, register, register, reset, setAutoReset, setClassLoader, setCopyReferences, setDefaultSerializer, setDefaultSerializer, setInstantiatorStrategy, setMaxDepth, setOptimizedGenerics, setReferenceResolver, setReferences, setRegistrationRequired, setWarnUnregisteredClasses, writeClass, writeObject, writeObject, writeObjectOrNull, writeObjectOrNull

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

forOutput

public static SchemaAwareKryo forOutput(SchemaI schema,
                                        java.io.OutputStream os,
                                        boolean asServer)

forInput

public static SchemaAwareKryo forInput(SchemaI schema,
                                       java.io.InputStream is)

writeClassAndObject

public void writeClassAndObject(java.lang.Object o)

flush

public void flush()
           throws java.io.IOException

Throws:

java.io.IOException

getCommonInputStream

public java.io.InputStream getCommonInputStream()

getCommonOutputStream

public java.io.OutputStream getCommonOutputStream()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

readClassAndObject

public java.lang.Object readClassAndObject()

writeClassAndObject

public void writeClassAndObject(com.esotericsoftware.kryo.io.Output output,
                                java.lang.Object o)

Overrides:

writeClassAndObject in class com.esotericsoftware.kryo.Kryo

getDefaultSerializer

public com.esotericsoftware.kryo.Serializer getDefaultSerializer(java.lang.Class type)

Overrides:

getDefaultSerializer in class com.esotericsoftware.kryo.Kryo

setReplaceBoBeforeWrite

public void setReplaceBoBeforeWrite(java.util.function.Function<Identifiable,Identifiable> replaceFunction)

setReplaceBoAfterRead

public void setReplaceBoAfterRead(java.util.function.Function<Identifiable,Identifiable> replaceFunction)