Interface | Description |
---|---|
ChannelSelector<T extends IOReadableWritable> |
The
ChannelSelector determines to which logical channels a record
should be written to. |
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.
|
RecordWriter<T extends IOReadableWritable> |
A record-oriented runtime result writer.
|
RoundRobinChannelSelector<T extends IOReadableWritable> |
This is the default implementation of the
ChannelSelector interface. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.