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 java.lang.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

DataInputToObjectCollectorSerializable()

Method Summary

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 java.io.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:

java.io.IOException - when the read operation cannot be completed