Package com.espertech.esper.common.internal.serde.serdeset.builtin

Class DIOSerializableObjectSerde

java.lang.Object

com.espertech.esper.common.internal.serde.serdeset.builtin.DIOSerializableObjectSerde

All Implemented Interfaces:

DataInputOutputSerde

public class DIOSerializableObjectSerde
extends Object
implements DataInputOutputSerde

Serde that serializes and de-serializes using ObjectInputStream and ObjectOutputStream.

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE
static final DIOSerializableObjectSerde	INSTANCE	Instance.

Method Summary

Modifier and Type	Method	Description
static Object	byteArrToObject(byte[] bytes)	Deserialize byte arry to object.
static Object	deserializeFrom(DataInput input)	Deserialize object
static byte[]	objectToByteArr(Object underlying)	Serialize object to byte array.
Object	read(DataInput input, byte[] resourceKey)	Read an object from the stream.
static void	serializeTo(Object value, DataOutput output)	Serialize object
void	write(Object object, DataOutput output, byte[] pageFullKey, EventBeanCollatedWriter writer)	Write an object to the stream.

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

INSTANCE

public static final DIOSerializableObjectSerde INSTANCE

Instance.

Method Details

write

public void write(Object object,
 DataOutput output,
 byte[] pageFullKey,
 EventBeanCollatedWriter writer)
           throws IOException

Description copied from interface: DataInputOutputSerde

Write an object to the stream.

Specified by:

write in interface DataInputOutputSerde

Parameters:

object - to write or null if this is a nullable value

output - to write to

pageFullKey - the page key of the page containing the object, can be null if not relevant or not provided

writer - the writer for events, can be null if not relevant or not provided

Throws:

IOException - for io exceptions

read

public Object read(DataInput input,
 byte[] resourceKey)
            throws IOException

Description copied from interface: DataInputOutputSerde

Read an object from the stream.

Specified by:

read in interface DataInputOutputSerde

Parameters:

input - input to read

resourceKey - the identifying key of the reader, can be null if not relevant or not provided

Returns:

object read or null if this is a nullable value

Throws:

IOException - for io exceptions

objectToByteArr

public static byte[] objectToByteArr(Object underlying)

Serialize object to byte array.

Parameters:

underlying - to serialize

Returns:

byte array

byteArrToObject

public static Object byteArrToObject(byte[] bytes)

Deserialize byte arry to object.

Parameters:

bytes - to read

Returns:

object

serializeTo

public static void serializeTo(Object value,
 DataOutput output)
                        throws IOException

Serialize object

Parameters:

value - value to serialize

output - output stream

Throws:

IOException - when a problem occurs

deserializeFrom

public static Object deserializeFrom(DataInput input)
                              throws IOException

Deserialize object

Parameters:

input - input stream

Returns:

value

Throws:

IOException - when a problem occurs