| Field Summary |
|
| public String | count
Refers to the number of the Abstract Dags which are being sent to the
Concrete Planner in response to the user's request. |
| public Vector | dagJobs
Vector of String objects containing the jobname_id of jobs making
the abstract dag. |
| public String | flowID
It is a unique identifier identifying the concrete DAG generated by Pegasus. |
| public String | flowIDName
It is the name of the dag as generated by Chimera in the dax. |
| public String | index
Refers to the number of the Dag. |
| public TreeMap | lfnMap
Contains a unique ordered listing of the logical names referred
to by the dag. |
| public String | nameOfADag
The name of the Abstract Dag taken from the adag element of the DAX
generated by the Abstract Planner. |
| public Vector | relations
Captures the parent child relations making up the DAG. |
| public String | releaseVersion
Identifies the release version of the VDS software that was
used to generate the workflow. |
| Method Summary |
|
| public void | addNewJob(SubInfo job)
Adds a new job to the dag. |
| 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 Object | clone()
Returns a new copy of the Object. |
| public void | generateFlowID()
Generates the flow id for this current run. |
| public void | generateFlowName()
Generates the name of the flow. |
| 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 String | getFlowTimestamp()
Returns the flow timestamp for the workflow. |
| public Set | getLFNs()
It returns the list of lfns referred to by the DAG. |
| public Set | getLFNs(boolean onlyInput)
Returns the list of lfns referred to by the DAG. |
| public String | getLabel()
Returns the label of the workflow, that was specified in the DAX. |
| public Vector | getLeafNodes()
This 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 Vector | getRootNodes()
It determines the root Nodes for the ADag looking at the relation pairs
of the adag. |
| public WorkflowMetrics | getWorkflowMetrics()
Returns the workflow metrics so far. |
| public boolean | remove(SubInfo job)
Removes a job from the dag/graph structure. |
| public void | setDAXMTime(String path)
Sets the mtime (last modified time) for the DAX. |
| public void | setFlowTimestamp(String timestamp)
Sets the flow timestamp for the workflow. |
| public void | setLabel(String label)
Sets the label for the workflow. |
| public void | setReleaseVersion()
Grabs the release version from VDS.Properties file. |
| public String | toString()
Returns the a textual description of the object. |
| public void | updateLFNMap(String lfn, String type)
Updates the lfn map, that contains the mapping of an lfn with the type.
Parameters:
lfn - the logical file name.
Parameters:
type - type the type of lfn (i|o|b). |
