Package com.espertech.esper.common.client.dataflow.io

Class DataInputToObjectCollectorSerializable

java.lang.Object

com.espertech.esper.common.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	Description
DataInputToObjectCollectorSerializable()

Method Summary

Modifier and Type	Method	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 Details

DataInputToObjectCollectorSerializable

public DataInputToObjectCollectorSerializable()

Method Details

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