org.apache.flink.streaming.runtime.partitioner

Class KeyGroupStreamPartitioner<T,K>

java.lang.Object

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

org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner<T,K>

Type Parameters:

T - Type of the elements in the Stream being partitioned

All Implemented Interfaces:

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

@Internal
public class KeyGroupStreamPartitioner<T,K>
extends StreamPartitioner<T>
implements ConfigurableStreamPartitioner

Partitioner selects the target channel based on the key group index.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyGroupStreamPartitioner(KeySelector<T,K> keySelector, int maxParallelism)

Method Summary

Modifier and Type	Method and Description
void	configure(int maxParallelism) Configure the StreamPartitioner with the maximum parallelism of the down stream operator.
StreamPartitioner<T>	copy()
int	getMaxParallelism()
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

KeyGroupStreamPartitioner

public KeyGroupStreamPartitioner(KeySelector<T,K> keySelector,
                                 int maxParallelism)

Method Detail

getMaxParallelism

public int getMaxParallelism()

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.

Specified by:

selectChannels in interface ChannelSelector<SerializationDelegate<StreamRecord<T>>>

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

configure

public void configure(int maxParallelism)

Description copied from interface: ConfigurableStreamPartitioner

Configure the StreamPartitioner with the maximum parallelism of the down stream operator.

Specified by:

configure in interface ConfigurableStreamPartitioner

Parameters:

maxParallelism - Maximum parallelism of the down stream operator.