edu.iu.dsc.tws.api.comms

Class LogicalPlan

java.lang.Object

edu.iu.dsc.tws.api.comms.LogicalPlan

public class LogicalPlan
extends java.lang.Object

Information about the instances in which the communication happens. This holds the mapping from the physical level communication addresses which are based on the communication library to high level ids that are defined by upper layers.

Constructor Summary

Constructors

Constructor and Description
LogicalPlan(java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> workerToLogicalId, java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> workerGroups, java.util.Map<java.lang.String,java.util.Set<java.lang.Integer>> nodeToLogicalId, int thisWorker)

Method Summary

Modifier and Type	Method and Description
void	addLogicalIdToWorker(int worker, int logicalId)
java.util.Set<java.lang.Integer>	getAllWorkers()
int	getGroupOfWorker(int worker)
int	getIndexOfTaskInNode(int task)
java.util.Set<java.lang.Integer>	getLogicalIdsOfThisWorker()
java.util.Set<java.lang.Integer>	getLogicalIdsOfWorker(int worker)
java.util.Map<java.lang.String,java.util.Set<java.lang.Integer>>	getNodeToLogicalId()
int	getThisWorker()
int	getWorkerForForLogicalId(int channel)
java.util.Set<java.lang.Integer>	getWorkersOfGroup(int group)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LogicalPlan

public LogicalPlan(java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> workerToLogicalId,
                   java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> workerGroups,
                   java.util.Map<java.lang.String,java.util.Set<java.lang.Integer>> nodeToLogicalId,
                   int thisWorker)

Method Detail

getWorkerForForLogicalId

public int getWorkerForForLogicalId(int channel)

getLogicalIdsOfWorker

public java.util.Set<java.lang.Integer> getLogicalIdsOfWorker(int worker)

getThisWorker

public int getThisWorker()

getAllWorkers

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

getWorkersOfGroup

public java.util.Set<java.lang.Integer> getWorkersOfGroup(int group)

getGroupOfWorker

public int getGroupOfWorker(int worker)

addLogicalIdToWorker

public void addLogicalIdToWorker(int worker,
                                 int logicalId)

getLogicalIdsOfThisWorker

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

getNodeToLogicalId

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

getIndexOfTaskInNode

public int getIndexOfTaskInNode(int task)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object