edu.iu.dsc.tws.examples.batch.sortop

Class ByteSelector

java.lang.Object

edu.iu.dsc.tws.examples.batch.sortop.ByteSelector

All Implemented Interfaces:

DestinationSelector

public class ByteSelector
extends java.lang.Object
implements DestinationSelector

Field Summary

Fields

Modifier and Type	Field and Description
protected int[]	destinationsList
protected int	keysToOneTask

Constructor Summary

Constructors

Constructor and Description
ByteSelector()

Method Summary

Modifier and Type	Method and Description
void	commit(int source, int obtained) 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

Field Detail

keysToOneTask

protected int keysToOneTask

destinationsList

protected int[] destinationsList

Constructor Detail

ByteSelector

public ByteSelector()

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

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

commit

public void commit(int source,
                   int obtained)

Description copied from interface: DestinationSelector

Say that we have used the obtained destination

Specified by:

commit in interface DestinationSelector

Parameters:

source - source

obtained - obtained destination