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 buffer-oriented runtime result writer API for producing results.
|
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.