Package org.apache.flink.runtime.io.network.api.writer

Interface Summary

Interface	Description
ChannelSelector<T extends IOReadableWritable>	The ChannelSelector determines to which logical channels a record should be written to.
RecordWriterDelegate<T extends IOReadableWritable>	The record writer delegate provides the availability function for task processor, and it might represent a single RecordWriter or multiple RecordWriter instances in specific implementations.
ResultPartitionWriter	A record-oriented runtime result writer API for producing results.

Class Summary

Class	Description
BroadcastRecordWriter<T extends IOReadableWritable>	A special record-oriented runtime result writer only for broadcast mode.
ChannelSelectorRecordWriter<T extends IOReadableWritable>	A regular record-oriented runtime result writer.
MultipleRecordWriters<T extends IOReadableWritable>	The specific delegate implementation for the multiple outputs case.
NonRecordWriter<T extends IOReadableWritable>	The specific delegate implementation for the non output case like sink task.
RecordWriter<T extends IOReadableWritable>	An abstract record-oriented runtime result writer.
RecordWriterBuilder<T extends IOReadableWritable>	Utility class to encapsulate the logic of building a RecordWriter instance.
RoundRobinChannelSelector<T extends IOReadableWritable>	This is the default implementation of the ChannelSelector interface.
SingleRecordWriter<T extends IOReadableWritable>	The specific delegate implementation for the single output case.

Enum Summary

Enum	Description
SubtaskStateMapper	The SubtaskStateMapper narrows down the subtasks that need to be read during rescaling to recover from a particular subtask when in-flight data has been stored in the checkpoint.