edu.iu.dsc.tws.comms.routing

Class DirectRouter

java.lang.Object

edu.iu.dsc.tws.comms.routing.DirectRouter

public class DirectRouter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
DirectRouter(LogicalPlan plan, java.util.List<java.lang.Integer> srscs, java.util.List<java.lang.Integer> dest) 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(int source)
java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>>	getInternalSendTasks(int source)
boolean	isLastReceiver() Return true if this is a last receiver
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

DirectRouter

public DirectRouter(LogicalPlan plan,
                    java.util.List<java.lang.Integer> srscs,
                    java.util.List<java.lang.Integer> dest)

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()

isLastReceiver

public boolean isLastReceiver()

Return true if this is a last receiver

Returns:

true

getInternalSendTasks

public 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.Set<java.lang.Integer>> getExternalSendTasks(int source)