edu.iu.dsc.tws.executor.comms

Class DefaultDestinationSelector

java.lang.Object

edu.iu.dsc.tws.executor.comms.DefaultDestinationSelector

All Implemented Interfaces:

DestinationSelector

public class DefaultDestinationSelector
extends java.lang.Object
implements DestinationSelector

Constructor Summary

Constructors

Constructor and Description
DefaultDestinationSelector(TaskPartitioner partitioner, java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndex, java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndex)

Method Summary

Modifier and Type	Method and Description
void	commit(int source, int next) Say that we have used the obtained destination
int	next(int source, java.lang.Object data) Get next destination using source and the data
int	next(int source, java.lang.Object key, java.lang.Object data) Get next destination using source, key and data
void	prepare(Communicator comm, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations) Prepare the destination selector

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.comms.DestinationSelector

prepare

Constructor Detail

DefaultDestinationSelector

public DefaultDestinationSelector(TaskPartitioner partitioner,
                                  java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndex,
                                  java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndex)

Method Detail

prepare

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

Description copied from interface: DestinationSelector

Prepare the destination selector

Specified by:

prepare in interface DestinationSelector

Parameters:

comm - the communicator

sources - sources

destinations - destination

next

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

Description copied from interface: DestinationSelector

Get next destination using source and the data

Specified by:

next in interface DestinationSelector

Parameters:

source - source

data - data

Returns:

the next destination

commit

public void commit(int source,
                   int next)

Description copied from interface: DestinationSelector

Say that we have used the obtained destination

Specified by:

commit in interface DestinationSelector

Parameters:

source - source

next - obtained destination

next

public int next(int source,
                java.lang.Object key,
                java.lang.Object data)

Description copied from interface: DestinationSelector

Get next destination using source, key and data

Specified by:

next in interface DestinationSelector

Parameters:

source - source

key - key

data - data

Returns:

the next destination