edu.iu.dsc.tws.api.compute.graph

Class ComputeGraph

java.lang.Object

edu.iu.dsc.tws.api.compute.graph.BaseDataflowTaskGraph<Vertex,Edge>

edu.iu.dsc.tws.api.compute.graph.ComputeGraph

All Implemented Interfaces:

ITaskGraph<Vertex,Edge>

public class ComputeGraph
extends BaseDataflowTaskGraph<Vertex,Edge>

This class extends the base data flow task graph which is mainly responsible for building the task graph for the task vertex and the task edge.

todo redundant ComputeGraph <- BaseDataflowTaskGraph <- ITaskGraph chain

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ComputeGraph.StringComparator

Constructor Summary

Constructors

Constructor and Description
ComputeGraph()
ComputeGraph(OperationMode mode)
ComputeGraph(OperationMode mode, java.lang.String graphName)

Method Summary

Modifier and Type	Method and Description
void	addGraphConstraints(java.util.Map<java.lang.String,java.lang.String> graphConstraintsmap)
void	addNodeConstraints(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsmap)
boolean	addTaskVertex(java.lang.String name, Vertex taskVertex) This method is responsible for adding the task vertex to the task map.
void	build() This method is responsible for storing the directed edges between the source and target task vertex in a map.
Vertex	childOfTask(Vertex task, java.lang.String edge)
java.util.Set<Vertex>	childrenOfTask(java.lang.String taskName)
java.util.Map<java.lang.String,java.lang.String>	getGraphConstraints()
java.lang.String	getGraphName()
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>	getNodeConstraints()
OperationMode	getOperationMode() This is the getter method to get the property of operation mode "STREAMING" or "BATCH".
Vertex	getParentOfTask(Vertex task, java.lang.String edge)
java.util.Set<Edge>	inEdges(java.lang.String taskName)
java.util.Set<Edge>	inEdges(Vertex task)
java.util.Set<Edge>	outEdges(java.lang.String taskName)
java.util.Set<Edge>	outEdges(Vertex task)
java.util.Set<Vertex>	parentsOfTask(java.lang.String taskName)
void	setGraphName(java.lang.String graphName)
void	setOperationMode(OperationMode operationMode) This is the setter method to set the property of the operation mode which is either "STREAMING" or "BATCH"
Vertex	vertex(java.lang.String name)

Methods inherited from class edu.iu.dsc.tws.api.compute.graph.BaseDataflowTaskGraph

addTaskEdge, addTaskEdge, addTaskVertex, childrenOfTask, connectedChildTask, connectedParentTask, containsTaskEdge, containsTaskEdge, containsTaskEdge, containsTaskVertex, getAllTaskEdges, getDataflowTaskEdge, getDirectedEdgesSet, getTaskVertexSet, hasCycle, incomingTaskEdgesOf, inDegreeOfTask, outDegreeOfTask, outgoingTaskEdgesOf, parentsOfTask, removeAllTaskEdges, removeAllTaskEdges, removeAllTaskVertices, removeTaskEdge, removeTaskEdge, removeTaskVertex, taskEdgeSet, taskEdgesOf, validate, validateTaskVertex

Methods inherited from class java.lang.Object

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

Constructor Detail

ComputeGraph

public ComputeGraph()

ComputeGraph

public ComputeGraph(OperationMode mode)

ComputeGraph

public ComputeGraph(OperationMode mode,
                    java.lang.String graphName)

Method Detail

build

public void build()

This method is responsible for storing the directed edges between the source and target task vertex in a map.

Specified by:

build in class BaseDataflowTaskGraph<Vertex,Edge>

getGraphName

public java.lang.String getGraphName()

setGraphName

public void setGraphName(java.lang.String graphName)

addTaskVertex

public boolean addTaskVertex(java.lang.String name,
                             Vertex taskVertex)

This method is responsible for adding the task vertex to the task map.

addNodeConstraints

public void addNodeConstraints(java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> nodeConstraintsmap)

addGraphConstraints

public void addGraphConstraints(java.util.Map<java.lang.String,java.lang.String> graphConstraintsmap)

getGraphConstraints

public java.util.Map<java.lang.String,java.lang.String> getGraphConstraints()

getNodeConstraints

public java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> getNodeConstraints()

vertex

public Vertex vertex(java.lang.String name)

outEdges

public java.util.Set<Edge> outEdges(Vertex task)

outEdges

public java.util.Set<Edge> outEdges(java.lang.String taskName)

inEdges

public java.util.Set<Edge> inEdges(Vertex task)

inEdges

public java.util.Set<Edge> inEdges(java.lang.String taskName)

childrenOfTask

public java.util.Set<Vertex> childrenOfTask(java.lang.String taskName)

parentsOfTask

public java.util.Set<Vertex> parentsOfTask(java.lang.String taskName)

childOfTask

public Vertex childOfTask(Vertex task,
                          java.lang.String edge)

getParentOfTask

public Vertex getParentOfTask(Vertex task,
                              java.lang.String edge)

getOperationMode

public OperationMode getOperationMode()

This is the getter method to get the property of operation mode "STREAMING" or "BATCH".

setOperationMode

public void setOperationMode(OperationMode operationMode)

This is the setter method to set the property of the operation mode which is either "STREAMING" or "BATCH"