Package org.apache.flink.streaming.runtime.io

Interface Summary

Interface	Description
CheckpointBarrierHandler	The CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input channels.

Class Summary

Class	Description
BarrierBuffer	The barrier buffer is CheckpointBarrierHandler that blocks inputs with barriers until all inputs have received the barrier for a given checkpoint.
BarrierTracker	The BarrierTracker keeps track of what checkpoint barriers have been received from which input channels.
BlockingQueueBroker	Broker for the BlockingQueue used in StreamIterationHead and StreamIterationTail for implementing feedback streams.
BufferSpiller	The buffer spiller takes the buffers and events from a data stream and adds them to a spill file.
BufferSpiller.SpilledBufferOrEventSequence	This class represents a sequence of spilled buffers and events, created by the BufferSpiller.
InputGateUtil	Utility for dealing with input gates.
RecordWriterOutput<OUT>	Implementation of Output that sends data using a RecordWriter.
StreamInputProcessor<IN>	Input reader for OneInputStreamTask.
StreamRecordWriter<T extends IOReadableWritable>	This record writer keeps data in buffers at most for a certain timeout.
StreamTwoInputProcessor<IN1,IN2>	Input reader for TwoInputStreamTask.