edu.iu.dsc.tws.tset.fn

Class LoadBalancePartitioner<T>

java.lang.Object

edu.iu.dsc.tws.tset.fn.LoadBalancePartitioner<T>

All Implemented Interfaces:

TaskPartitioner<T>, PartitionFunc<T>, java.io.Serializable

public class LoadBalancePartitioner<T>
extends java.lang.Object
implements PartitionFunc<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LoadBalancePartitioner()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

LoadBalancePartitioner

public LoadBalancePartitioner()

Method Detail

prepare

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

Description copied from interface: PartitionFunc

Prepare the function

Specified by:

prepare in interface TaskPartitioner<T>

Specified by:

prepare in interface PartitionFunc<T>

Parameters:

sources - source

destinations - destinations

partition

public int partition(int sourceIndex,
                     T val)

Description copied from interface: PartitionFunc

Computes the partition for the given key.

Specified by:

partition in interface TaskPartitioner<T>

Specified by:

partition in interface PartitionFunc<T>

Parameters:

sourceIndex - source of the data

val - value.

Returns:

The partition index.

commit

public void commit(int source,
                   int partition)

Description copied from interface: PartitionFunc

Commit the partition

Specified by:

commit in interface TaskPartitioner<T>

Specified by:

commit in interface PartitionFunc<T>

Parameters:

source - the source

partition - partition