edu.iu.dsc.tws.comms.routing

Class PartitionRouter

java.lang.Object

edu.iu.dsc.tws.comms.routing.PartitionRouter

public class PartitionRouter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
PartitionRouter(LogicalPlan plan, java.util.Set<java.lang.Integer> srscs, java.util.Set<java.lang.Integer> dests) Create a direct router

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>	getExternalSendTasks()
java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>	getInternalSendTasks()
int	mainTaskOfExecutor()
java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>>	partialExpectedTaskIds()
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

PartitionRouter

public PartitionRouter(LogicalPlan plan,
                       java.util.Set<java.lang.Integer> srscs,
                       java.util.Set<java.lang.Integer> dests)

Create a direct router

Method Detail

receivingExecutors

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

receiveExpectedTaskIds

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

partialExpectedTaskIds

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

getInternalSendTasks

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

getExternalSendTasks

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

mainTaskOfExecutor

public int mainTaskOfExecutor()