Method Summary |
|
public void | add(SubInfo job) This adds a new job to the ADAG object. |
public void | addNewRelation(String parent, String child) Adds a new PCRelation pair to the Vector of PCRelation
pairs. |
public void | addNewRelation(String parent, String child, boolean isDeleted) Adds a new PCRelation pair to the Vector of PCRelation
pairs. |
public void | clearJobs() Removes all the jobs from the workflow, and all the edges between
the workflows. |
public Object | clone() Returns a new copy of the Object. |
public String | getBaseSubmitDirectory() Returns the root of submit directory hierarchy for the workflow. |
public Vector | getChildren(String node) Get all the children of a particular node.
Parameters: node - the name of the node whose children we want to find. |
public Set | getExecutionSites() It returns the a unique list of the execution sites that the Planner
has mapped the dax to so far in it's stage of planning . |
public String | getLabel() Returns the label of the workflow, that was specified in the DAX. |
public Vector | getLeafNodes() Returns all the leaf nodes of the dag. |
public String | getMTime() Returns the last modified time for the file containing the workflow
description. |
public int | getNoOfJobs() Returns the number of jobs in the dag on the basis of number of elements
in the dagJobs Vector. |
public Vector | getParents(String node) Gets all the parents of a particular node
Parameters: node - the name of the job whose parents are to be found. |
public String | getRequestID() Returns the request id. |
public Vector | getRootNodes() It determines the root Nodes for the ADag looking at the relation pairs
of the adag. |
public SubInfo | getSubInfo(String job) This returns a SubInfo object corresponding to the job by looking through
all the subInfos.
Parameters: job - jobName of the job for which we need the subInfo object. |
public WorkflowMetrics | getWorkflowMetrics() Returns the metrics about the workflow. |
public boolean | isEmpty() Returns whether the workflow is empty or not. |
public Iterator | jobIterator() Returns an iterator for traversing through the jobs in the workflow. |
public boolean | remove(SubInfo job) Removes a particular job from the workflow. |
public void | setBaseSubmitDirectory(String dir) Sets the submit directory for the workflow. |
public void | setRequestID(String id) Sets the request id. |
public String | toDOT() Returns the DOT description of the object. |
public void | toDOT(Writer stream, String indent) Returns the DOT description of the object. |
public String | toString() Returns the String description of the dag associated with this object. |
public void | writeDOTHeader(Writer stream, String indent) Writes out the static DOT Header.
Parameters: stream - is a stream opened and ready for writing. |