Modifier and Type | Field and Description |
---|---|
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.
|
Vector |
dagJobs
Vector of String objects containing the jobname_id of jobs making
the abstract dag.
|
private static String |
DEFAULT_NAME
The default name for the ADag object, if not supplied in the DAX.
|
String |
flowID
It is a unique identifier identifying the concrete DAG generated by Pegasus.
|
String |
flowIDName
It is the name of the dag as generated by Chimera in the dax.
|
String |
index
Refers to the number of the Dag.
|
TreeMap |
lfnMap
Contains a unique ordered listing of the logical names referred
to by the dag.
|
private String |
mDAXMTime
Keeps the last modified time of the DAX.
|
private String |
mDAXVersion
The DAX Version
|
private String |
mFlowTimestamp
The ISO timestamp corresponding to the time when Pegasus is invoked for a
dax.
|
private WorkflowMetrics |
mWFMetrics
The workflow metric objects that contains metrics about the workflow being
planned.
|
String |
nameOfADag
The name of the Abstract Dag taken from the adag element of the DAX
generated by the Abstract Planner.
|
Vector |
relations
Captures the parent child relations making up the DAG.
|
String |
releaseVersion
Identifies the release version of the VDS software that was
used to generate the workflow.
|
Constructor and Description |
---|
DagInfo()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
addNewJob(Job job)
Adds a new job to the dag.
|
void |
addNewRelation(PCRelation relation)
Adds a new PCRelation pair to the Vector of
PCRelation
pairs. |
void |
addNewRelation(String parent,
String child)
Adds a new PCRelation pair to the Vector of
PCRelation
pairs. |
void |
addNewRelation(String parent,
String child,
boolean isDeleted)
Adds a new PCRelation pair to the Vector of
PCRelation pairs. |
Object |
clone()
Returns a new copy of the Object.
|
void |
generateFlowID()
Generates the flow id for this current run.
|
void |
generateFlowName()
Generates the name of the flow.
|
Vector |
getChildren(String node)
Get all the children of a particular node.
|
String |
getDAXVersion()
Returns the dax version
|
String |
getFlowTimestamp()
Returns the flow timestamp for the workflow.
|
String |
getLabel()
Returns the label of the workflow, that was specified in the DAX.
|
Vector |
getLeafNodes()
This returns all the leaf nodes of the dag.
|
Set |
getLFNs()
It returns the list of lfns referred to by the DAG.
|
Set |
getLFNs(boolean onlyInput)
Returns the list of lfns referred to by the DAG.
|
String |
getMTime()
Returns the last modified time for the file containing the workflow
description.
|
int |
getNoOfJobs()
Returns the number of jobs in the dag on the basis of number of elements
in the
dagJobs Vector. |
Vector |
getParents(String node)
Gets all the parents of a particular node.
|
Vector |
getRootNodes()
It determines the root Nodes for the ADag looking at the relation pairs
of the adag.
|
WorkflowMetrics |
getWorkflowMetrics()
Returns the workflow metrics so far.
|
boolean |
remove(Job job)
Removes a job from the dag/graph structure.
|
void |
setDAXMTime(File f)
Sets the mtime (last modified time) for the DAX.
|
void |
setDAXMTime(String time)
Sets the mtime (last modified time) for the DAX.
|
void |
setDAXVersion(String version)
Sets the dax version
|
void |
setFlowTimestamp(String timestamp)
Sets the flow timestamp for the workflow.
|
void |
setLabel(String label)
Sets the label for the workflow.
|
void |
setReleaseVersion()
Grabs the release version from VDS.Properties file.
|
String |
toString()
Returns the a textual description of the object.
|
void |
updateLFNMap(String lfn,
String type)
Updates the lfn map, that contains the mapping of an lfn with the type.
|
setToString, vectorToString
private static final String DEFAULT_NAME
public Vector dagJobs
public Vector relations
PCRelation
objects.public String nameOfADag
public String count
public String index
public String flowID
flowIDName
,
mFlowTimestamp
public String flowIDName
private String mFlowTimestamp
private String mDAXMTime
public String releaseVersion
org.griphyn.common.util.Version
private WorkflowMetrics mWFMetrics
public TreeMap lfnMap
private String mDAXVersion
public void addNewJob(Job job)
job
- the job to be addedpublic void addNewRelation(PCRelation relation)
PCRelation
pairs. Since we are adding a new relation the isDeleted parameter should
be falserelation
- the relation to be addedpublic void addNewRelation(String parent, String child)
PCRelation
pairs. Since we are adding a new relation the isDeleted parameter should
be false.parent
- The parent in the relation pairchild
- The child in the relation pairrelations
public void addNewRelation(String parent, String child, boolean isDeleted)
PCRelation
pairs.parent
- The parent in the relation pairchild
- The child in the relation pairisDeleted
- Whether the relation has been deleted due to the
reduction algorithm or notrelations
public boolean remove(Job job)
job
- the job to be removedpublic Set getLFNs()
String objects corresponding to the
logical filenames
public Set getLFNs(boolean onlyInput)
onlyInput
- a boolean flag indicating that you need only the input
files to the whole workflowpublic String getLabel()
public String getDAXVersion()
public String getMTime()
public String getFlowTimestamp()
public void setFlowTimestamp(String timestamp)
timestamp
- the flowtimestamppublic int getNoOfJobs()
dagJobs
Vector.public Vector getParents(String node)
node
- the name of the job whose parents are to be found.public Vector getChildren(String node)
node
- the name of the node whose children we want to find.public Vector getLeafNodes()
String
corresponding to the job names of
the leaf nodes.org.griphyn.cPlanner.classes.PCRelation
,
org.griphyn.cPlanner.classes.DagInfo#relations
public Vector getRootNodes()
org.griphyn.cPlanner.classes.PCRelation
,
org.griphyn.cPlanner.classes.DagInfo#relations
public WorkflowMetrics getWorkflowMetrics()
public void generateFlowID()
public void generateFlowName()
public void setLabel(String label)
label
- the label to be assigned to the workflowpublic void setDAXVersion(String version)
version
- the version of the DAXpublic void setDAXMTime(File f)
f
- the file descriptor to the DAX|PDAX file.public void setDAXMTime(String time)
time
- iso formatted time string indicating the last modified time
of DAXpublic void setReleaseVersion()
org.griphyn.common.util.Version
public void updateLFNMap(String lfn, String type)
lfn
- the logical file name.type
- type the type of lfn (i|o|b). usually a character.public Object clone()
Copyright © 2011 The University of Southern California. All Rights Reserved.