Uses of Interface
org.apache.flink.runtime.io.network.api.writer.ChannelSelector

Packages that use ChannelSelector

Package	Description
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.operators.shipping
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.partitioner

Uses of ChannelSelector in org.apache.flink.runtime.io.network.api.writer

Classes in org.apache.flink.runtime.io.network.api.writer that implement ChannelSelector

Modifier and Type	Class and Description
class	RoundRobinChannelSelector<T extends IOReadableWritable> This is the default implementation of the ChannelSelector interface.

Constructors in org.apache.flink.runtime.io.network.api.writer with parameters of type ChannelSelector

Constructor and Description
RecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector)
RecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector, boolean flushAlways)

Uses of ChannelSelector in org.apache.flink.runtime.operators.shipping

Classes in org.apache.flink.runtime.operators.shipping that implement ChannelSelector

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.

Uses of ChannelSelector in org.apache.flink.streaming.runtime.io

Constructors in org.apache.flink.streaming.runtime.io with parameters of type ChannelSelector

Constructor and Description
StreamRecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector, long timeout)
StreamRecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector, long timeout, String taskName)

Uses of ChannelSelector in org.apache.flink.streaming.runtime.partitioner

Classes in org.apache.flink.streaming.runtime.partitioner that implement ChannelSelector

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.