edu.isi.pegasus.planner.classes
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 |
getIndex() |
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 getIndex()
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()