com.espertech.esper.client.dataflow.io

Class DataInputToObjectCollectorSerializable

java.lang.Object

com.espertech.esper.client.dataflow.io.DataInputToObjectCollectorSerializable

All Implemented Interfaces:

DataInputToObjectCollector

public class DataInputToObjectCollectorSerializable
extends Object
implements DataInputToObjectCollector

Reads a Serializable from DataInput and emits the resulting object.

The input must carry an int-typed number of bytes followed by the serialized object.

Constructor Summary

Constructors

Constructor and Description
DataInputToObjectCollectorSerializable()

Method Summary

Modifier and Type	Method and Description
void	collect(DataInputToObjectCollectorContext context) Reads provided DataInput and emits an object using the provided emitter.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataInputToObjectCollectorSerializable

public DataInputToObjectCollectorSerializable()

Method Detail

collect

public void collect(DataInputToObjectCollectorContext context)
             throws IOException

Description copied from interface: DataInputToObjectCollector

Reads provided DataInput and emits an object using the provided emitter.

Specified by:

collect in interface DataInputToObjectCollector

Parameters:

context - contains input and emitter

Throws:

IOException - when the read operation cannot be completed