edu.iu.dsc.tws.comms.routing

Class KeyedInvertedBinaryTreeRouter

java.lang.Object

edu.iu.dsc.tws.comms.routing.KeyedInvertedBinaryTreeRouter

public class KeyedInvertedBinaryTreeRouter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
KeyedInvertedBinaryTreeRouter(Config cfg, LogicalPlan plan, java.util.Set<java.lang.Integer> roots, java.util.Set<java.lang.Integer> dests) Initialize the data structure

Method Summary

Modifier and Type	Method and Description
int	destinationIdentifier(int source, int path)
java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>>	getExternalSendTasks(int source)
java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>>	getExternalSendTasksForPartial(int source)
java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>>	getInternalSendTasks(int source)
java.util.Map<java.lang.Integer,java.lang.Integer>	getPathAssignedToTasks()
boolean	isLastReceiver()
int	mainTaskOfExecutor(int executor, int path)
java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>>>	receiveExpectedTaskIds()
java.util.Set<java.lang.Integer>	receivingExecutors()

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyedInvertedBinaryTreeRouter

public KeyedInvertedBinaryTreeRouter(Config cfg,
                                     LogicalPlan plan,
                                     java.util.Set<java.lang.Integer> roots,
                                     java.util.Set<java.lang.Integer> dests)

Initialize the data structure

Parameters:

cfg -

plan -

roots -

dests -

Method Detail

receivingExecutors

public java.util.Set<java.lang.Integer> receivingExecutors()

receiveExpectedTaskIds

public java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>>> receiveExpectedTaskIds()

isLastReceiver

public boolean isLastReceiver()

getInternalSendTasks

public java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>> getInternalSendTasks(int source)

getExternalSendTasks

public java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>> getExternalSendTasks(int source)

getExternalSendTasksForPartial

public java.util.Map<java.lang.Integer,java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>> getExternalSendTasksForPartial(int source)

mainTaskOfExecutor

public int mainTaskOfExecutor(int executor,
                              int path)

destinationIdentifier

public int destinationIdentifier(int source,
                                 int path)

getPathAssignedToTasks

public java.util.Map<java.lang.Integer,java.lang.Integer> getPathAssignedToTasks()