org.apache.flink.state.api.output.partitioner

Class KeyGroupRangePartitioner

java.lang.Object

org.apache.flink.state.api.output.partitioner.KeyGroupRangePartitioner

All Implemented Interfaces:

Serializable, Function, Partitioner<Integer>

@Internal
public class KeyGroupRangePartitioner
extends Object
implements Partitioner<Integer>

A partitioner that selects the target channel based on the key group index.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KeyGroupRangePartitioner(int maxParallelism)

Method Summary

Modifier and Type	Method and Description
int	partition(Integer key, int numPartitions) Computes the partition for the given key.

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyGroupRangePartitioner

public KeyGroupRangePartitioner(int maxParallelism)

Method Detail

partition

public int partition(Integer key,
                     int numPartitions)

Description copied from interface: Partitioner

Computes the partition for the given key.

Specified by:

partition in interface Partitioner<Integer>

Parameters:

key - The key.

numPartitions - The number of partitions to partition into.

Returns:

The partition index.