org.apache.flink.contrib.streaming.state

Interface ShardedConnection.Partitioner

All Superinterfaces:

Serializable

All Known Implementing Classes:

ShardedConnection.ModHashPartitioner

Enclosing class:

ShardedConnection

public static interface ShardedConnection.Partitioner
extends Serializable

Method Summary

Modifier and Type	Method and Description
int	getShardIndex(Object key, int numShards)

Method Detail

getShardIndex

int getShardIndex(Object key,
                  int numShards)