Package 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, org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.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	Description
KeyGroupStreamPartitioner(org.apache.flink.api.java.functions.KeySelector<T,K> keySelector, int maxParallelism)

Method Summary

Modifier and Type	Method	Description
void	configure(int maxParallelism)	Configure the StreamPartitioner with the maximum parallelism of the down stream operator.
StreamPartitioner<T>	copy()
boolean	equals(Object o)
org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper	getDownstreamSubtaskStateMapper()	Defines the behavior of this partitioner, when downstream rescaled during recovery of in-flight data.
int	getMaxParallelism()
int	hashCode()
boolean	isPointwise()
int	selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>> record)
String	toString()

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

disableUnalignedCheckpoints, getUpstreamSubtaskStateMapper, isBroadcast, isSupportsUnalignedCheckpoint, setup

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KeyGroupStreamPartitioner

public KeyGroupStreamPartitioner(org.apache.flink.api.java.functions.KeySelector<T,K> keySelector,
                                 int maxParallelism)

Method Detail

getMaxParallelism

public int getMaxParallelism()

selectChannel

public int selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>> record)

Specified by:

selectChannel in interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>

getDownstreamSubtaskStateMapper

public org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper getDownstreamSubtaskStateMapper()

Description copied from class: StreamPartitioner

Defines the behavior of this partitioner, when downstream rescaled during recovery of in-flight data.

Specified by:

getDownstreamSubtaskStateMapper in class StreamPartitioner<T>

copy

public StreamPartitioner<T> copy()

Specified by:

copy in class StreamPartitioner<T>

isPointwise

public boolean isPointwise()

Specified by:

isPointwise 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.

equals

public boolean equals(Object o)

Overrides:

equals in class StreamPartitioner<T>

hashCode

public int hashCode()

Overrides:

hashCode in class StreamPartitioner<T>