Package org.apache.nemo.runtime.executor.datatransfer

Interface Summary

Interface	Description
InputReader	Represents the input data transfer to a task.
InputWatermarkManager	An interface for tracking input watermarks among multiple input streams.
OutputWriter	Represents the output data transfer from a task.

Class Summary

Class	Description
BlockInputReader	Represents the input data transfer to a task.
BlockOutputWriter	Represents the output data transfer from a task.
DataFetcherOutputCollector<O>	This collector receives data from DataFetcher and forwards it to the next operator.
IntermediateDataIOFactory	A factory that produces InputReader and OutputWriter.
MultiInputWatermarkManager	This tracks the minimum input watermark among multiple input streams.
NemoEventDecoderFactory	A factory for NemoEventDecoder.
NemoEventEncoderFactory	A factory for NemoEventEncoder.
NextIntraTaskOperatorInfo	Contains information for next operator: -- edgeIndex: the index of edge to next operator.
OperatorVertexOutputCollector<O>	OutputCollector implementation.
OperatorWatermarkCollector	This class is used for collecting watermarks for an OperatorVertex.
PipeInputReader	Represents the input data transfer to a task.
PipeOutputWriter	Represents the output data transfer from a task.
RunTimeMessageOutputCollector<O>	OutputCollector for dynamic optimization data.
SingleInputWatermarkManager	This is a special implementation for single input data stream for optimization.
WatermarkWithIndex	This contains a watermark and the src task index.