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 -
-
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 Description classRoundRobinChannelSelector<T extends org.apache.flink.core.io.IOReadableWritable>This is the default implementation of theChannelSelectorinterface.Methods in org.apache.flink.runtime.io.network.api.writer that return ChannelSelector Modifier and Type Method Description ChannelSelector<T>ChannelSelectorRecordWriter. getChannelSelector()Methods in org.apache.flink.runtime.io.network.api.writer with parameters of type ChannelSelector Modifier and Type Method Description RecordWriterBuilder<T>RecordWriterBuilder. setChannelSelector(ChannelSelector<T> selector) -
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 Description classOutputEmitter<T>The output emitter decides to which of the possibly multiple output channels a record is sent.
-