org.apache.flink.runtime.operators.shipping

Class RecordOutputEmitter

java.lang.Object

org.apache.flink.runtime.operators.shipping.RecordOutputEmitter

All Implemented Interfaces:

ChannelSelector<org.apache.flink.types.Record>

public class RecordOutputEmitter
extends Object
implements ChannelSelector<org.apache.flink.types.Record>

Constructor Summary

Constructors

Constructor and Description
RecordOutputEmitter(ShipStrategyType strategy) Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...).
RecordOutputEmitter(ShipStrategyType strategy, org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator) Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) and uses the supplied comparator to hash / compare records for partitioning them deterministically.
RecordOutputEmitter(ShipStrategyType strategy, org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator, org.apache.flink.api.common.distributions.DataDistribution distr) Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) and uses the supplied comparator to hash / compare records for partitioning them deterministically.
RecordOutputEmitter(ShipStrategyType strategy, org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator, org.apache.flink.api.common.functions.Partitioner<?> partitioner)
RecordOutputEmitter(ShipStrategyType strategy, org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator, org.apache.flink.api.common.functions.Partitioner<?> partitioner, org.apache.flink.api.common.distributions.DataDistribution distr)

Method Summary

Modifier and Type	Method and Description
int[]	selectChannels(org.apache.flink.types.Record record, int numberOfChannels) Returns the logical channel indexes, to which the given record should be written.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecordOutputEmitter

public RecordOutputEmitter(ShipStrategyType strategy)

Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...).

Parameters:

strategy - The distribution strategy to be used.

RecordOutputEmitter

public RecordOutputEmitter(ShipStrategyType strategy,
                           org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator)

Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) and uses the supplied comparator to hash / compare records for partitioning them deterministically.

Parameters:

strategy - The distribution strategy to be used.

comparator - The comparator used to hash / compare the records.

RecordOutputEmitter

public RecordOutputEmitter(ShipStrategyType strategy,
                           org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator,
                           org.apache.flink.api.common.distributions.DataDistribution distr)

Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...) and uses the supplied comparator to hash / compare records for partitioning them deterministically.

Parameters:

strategy - The distribution strategy to be used.

comparator - The comparator used to hash / compare the records.

distr - The distribution pattern used in the case of a range partitioning.

RecordOutputEmitter

public RecordOutputEmitter(ShipStrategyType strategy,
                           org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator,
                           org.apache.flink.api.common.functions.Partitioner<?> partitioner)

RecordOutputEmitter

public RecordOutputEmitter(ShipStrategyType strategy,
                           org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.types.Record> comparator,
                           org.apache.flink.api.common.functions.Partitioner<?> partitioner,
                           org.apache.flink.api.common.distributions.DataDistribution distr)

Method Detail

selectChannels

public final int[] selectChannels(org.apache.flink.types.Record record,
                                  int numberOfChannels)

Description copied from interface: ChannelSelector

Returns the logical channel indexes, to which the given record should be written.

Specified by:

selectChannels in interface ChannelSelector<org.apache.flink.types.Record>

Parameters:

record - the record to the determine the output channels for

numberOfChannels - the total number of output channels which are attached to respective output gate

Returns:

a (possibly empty) array of integer numbers which indicate the indices of the output channels through which the record shall be forwarded