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

Field Summary

Fields inherited from class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner

numberOfChannels

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	selectChannel(SerializationDelegate<StreamRecord<T>> record) Returns the logical channel index, to which the given record should be written.
String	toString()

Methods inherited from class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner

isBroadcast, setup

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()

selectChannel

public int selectChannel(SerializationDelegate<StreamRecord<T>> record)

Description copied from interface: ChannelSelector

Returns the logical channel index, to which the given record should be written. It is illegal to call this method for broadcast channel selectors and this method can remain not implemented in that case (for example by throwing UnsupportedOperationException).

Specified by:

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

Parameters:

record - the record to determine the output channels for.

Returns:

an integer number which indicates the index of the output channel 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.