org.apache.flink.streaming.runtime.partitioner

Class RebalancePartitioner<T>

java.lang.Object

org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T>

org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner<T>

Type Parameters:

T - Type of the elements in the Stream being rebalanced

All Implemented Interfaces:

Serializable, ChannelSelector<SerializationDelegate<StreamRecord<T>>>

@Internal
public class RebalancePartitioner<T>
extends StreamPartitioner<T>

Partitioner that distributes the data equally by cycling through the output channels.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RebalancePartitioner()

Method Summary

Modifier and Type	Method and Description
StreamPartitioner<T>	copy()
int[]	selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels) Returns the logical channel indexes, to which the given record should be written.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RebalancePartitioner

public RebalancePartitioner()

Method Detail

selectChannels

public int[] selectChannels(SerializationDelegate<StreamRecord<T>> record,
                            int numberOfOutputChannels)

Description copied from interface: ChannelSelector

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

Parameters:

record - the record to the determine the output channels for

numberOfOutputChannels - 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

copy

public StreamPartitioner<T> copy()

Specified by:

copy in class StreamPartitioner<T>

toString

public String toString()

Overrides:

toString in class Object