edu.iu.dsc.tws.examples.utils.partitioners

Class DeterministicTaskPartitioner

java.lang.Object

edu.iu.dsc.tws.examples.utils.partitioners.DeterministicTaskPartitioner

All Implemented Interfaces:

TaskPartitioner, java.io.Serializable

public class DeterministicTaskPartitioner
extends java.lang.Object
implements TaskPartitioner

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DeterministicTaskPartitioner()

Method Summary

Modifier and Type	Method and Description
void	commit(int source, int partition) Indicate that we are using this partition
int	partition(int source, java.lang.Object data) Get a partition id, it should be from the set of destinations
void	prepare(java.util.Set sources, java.util.Set destinations) Prepare the partition with sources and destinations.

Methods inherited from class java.lang.Object

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

Constructor Detail

DeterministicTaskPartitioner

public DeterministicTaskPartitioner()

Method Detail

prepare

public void prepare(java.util.Set sources,
                    java.util.Set destinations)

Description copied from interface: TaskPartitioner

Prepare the partition with sources and destinations. The sources have values to partition and the partitions should be among destinations

Specified by:

prepare in interface TaskPartitioner

partition

public int partition(int source,
                     java.lang.Object data)

Description copied from interface: TaskPartitioner

Get a partition id, it should be from the set of destinations

Specified by:

partition in interface TaskPartitioner

Parameters:

source - source of the data

data - data to be partitioned

Returns:

partition id

commit

public void commit(int source,
                   int partition)

Description copied from interface: TaskPartitioner

Indicate that we are using this partition

Specified by:

commit in interface TaskPartitioner

Parameters:

source - source of the partition

partition - partition to commit