Package | Description |
---|---|
org.apache.flink.runtime.io.network.api.writer | |
org.apache.flink.runtime.operators.shipping | |
org.apache.flink.streaming.runtime.partitioner |
Modifier and Type | Class and Description |
---|---|
class |
RoundRobinChannelSelector<T extends IOReadableWritable>
This is the default implementation of the
ChannelSelector interface. |
Modifier and Type | Method and Description |
---|---|
static RecordWriter |
RecordWriter.createRecordWriter(ResultPartitionWriter writer,
ChannelSelector channelSelector,
long timeout,
String taskName) |
static RecordWriter |
RecordWriter.createRecordWriter(ResultPartitionWriter writer,
ChannelSelector channelSelector,
String taskName) |
Constructor and Description |
---|
BroadcastRecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector,
long timeout,
String taskName) |
RecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector,
long timeout,
String taskName) |
Modifier and Type | Class and Description |
---|---|
class |
OutputEmitter<T>
The output emitter decides to which of the possibly multiple output channels a record is sent.
|
Modifier and Type | Class and Description |
---|---|
class |
BroadcastPartitioner<T>
Partitioner that selects all the output channels.
|
class |
CustomPartitionerWrapper<K,T>
Partitioner that selects the channel with a user defined partitioner function on a key.
|
class |
ForwardPartitioner<T>
Partitioner that forwards elements only to the locally running downstream operation.
|
class |
GlobalPartitioner<T>
Partitioner that sends all elements to the downstream operator with subtask ID=0.
|
class |
KeyGroupStreamPartitioner<T,K>
Partitioner selects the target channel based on the key group index.
|
class |
RebalancePartitioner<T>
Partitioner that distributes the data equally by cycling through the output
channels.
|
class |
RescalePartitioner<T>
Partitioner that distributes the data equally by cycling through the output
channels.
|
class |
ShufflePartitioner<T>
Partitioner that distributes the data equally by selecting one output channel
randomly.
|
class |
StreamPartitioner<T>
A special
ChannelSelector for use in streaming programs. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.