edu.iu.dsc.tws.api.tset.fn

Interface PartitionFunc<T>

Type Parameters:

T - the type of data

All Superinterfaces:

java.io.Serializable, TaskPartitioner<T>

All Known Implementing Classes:

HashingPartitioner, LoadBalancePartitioner, OneToOnePartitioner

public interface PartitionFunc<T>
extends java.io.Serializable, TaskPartitioner<T>

Given a data, give the partition index

Method Summary

Modifier and Type	Method and Description
default void	commit(int source, int partition) Commit the partition
int	partition(int sourceIndex, T val) Computes the partition for the given key.
default void	prepare(java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations) Prepare the function

Method Detail

prepare

default void prepare(java.util.Set<java.lang.Integer> sources,
                     java.util.Set<java.lang.Integer> destinations)

Prepare the function

Specified by:

prepare in interface TaskPartitioner<T>

Parameters:

sources - source

destinations - destinations

partition

int partition(int sourceIndex,
              T val)

Computes the partition for the given key.

Specified by:

partition in interface TaskPartitioner<T>

Parameters:

val - value.

sourceIndex - source of the data

Returns:

The partition index.

commit

default void commit(int source,
                    int partition)

Commit the partition

Specified by:

commit in interface TaskPartitioner<T>

Parameters:

source - the source

partition - partition