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

Packages that use org.apache.flink.streaming.runtime.io

Package	Description
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Classes in org.apache.flink.streaming.runtime.io used by org.apache.flink.streaming.runtime.io

Class and Description
BlockingQueueBroker Broker for the BlockingQueue used in StreamIterationHead and StreamIterationTail for implementing feedback streams.
BufferBlocker The buffer blocker takes the buffers and events from a data stream and adds them in a sequence.
BufferOrEventSequence This class represents a sequence of buffers and events which are blocked by CheckpointBarrierHandler.
CheckpointBarrierHandler The CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input channels.
StreamRecordWriter This record writer keeps data in buffers at most for a certain timeout.

Classes in org.apache.flink.streaming.runtime.io used by org.apache.flink.streaming.runtime.tasks

Class and Description
RecordWriterOutput Implementation of Output that sends data using a RecordWriter.
StreamRecordWriter This record writer keeps data in buffers at most for a certain timeout.