Package org.apache.beam.sdk.transforms

Interface Partition.PartitionWithSideInputsFn<T>

Type Parameters:

T - the type of the elements being partitioned

All Superinterfaces:

Serializable

Enclosing class:

Partition<T>

public static interface Partition.PartitionWithSideInputsFn<T>
extends Serializable

A function object that chooses an output partition for an element.

Method Summary

Modifier and Type	Method	Description
int	partitionFor(T elem, int numPartitions, Contextful.Fn.Context c)	Chooses the partition into which to put the given element.

Method Details

partitionFor

int partitionFor(T elem,
 int numPartitions,
 Contextful.Fn.Context c)

Chooses the partition into which to put the given element.

Parameters:

elem - the element to be partitioned

numPartitions - the total number of partitions (>= 1)

c - the Contextful.Fn.Context needed to access sideInputs.

Returns:

index of the selected partition (in the range [0..numPartitions-1])