public class DagInfo extends Data
Modifier and Type | Field and Description |
---|---|
private static java.lang.String |
DEFAULT_NAME
The default name for the ADag object, if not supplied in the DAX.
|
java.util.TreeMap |
lfnMap
Contains a unique ordered listing of the logical names referred
to by the dag.
|
private java.lang.String |
mCount
Refers to the number of the Abstract Dags which are being sent to the
Concrete Planner in response to the user's request.
|
private java.lang.String |
mDAXMTime
Keeps the last modified time of the DAX.
|
private java.lang.String |
mDAXVersion
The DAX Version
|
private java.lang.String |
mFlowID
It is a unique identifier identifying the concrete DAG generated by Pegasus.
|
private java.lang.String |
mFlowIDName
It is the name of the dag as generated by Chimera in the dax.
|
private java.lang.String |
mFlowTimestamp
The ISO timestamp corresponding to the time when Pegasus is invoked for a
dax.
|
private java.lang.String |
mIndex
Refers to the number of the Dag.
|
private java.lang.String |
mNameOfADag
The name of the Abstract Dag taken from the adag element of the DAX
generated by the Abstract Planner.
|
private java.lang.String |
mReleaseVersion
Identifies the release version of the VDS software that was
used to generate the workflow.
|
private WorkflowMetrics |
mWFMetrics
The workflow metric objects that contains metrics about the workflow being
planned.
|
Constructor and Description |
---|
DagInfo()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
java.lang.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.
|
java.lang.String |
getCount()
Returns the count of the workflow, that was specified in the DAX.
|
java.lang.String |
getDAXVersion()
Returns the dax version
|
java.lang.String |
getFlowID()
Returns the generated flow ID for the workflow.
|
java.lang.String |
getFlowName()
Returns the flow name
|
java.lang.String |
getFlowTimestamp()
Returns the flow timestamp for the workflow.
|
java.lang.String |
getIndex() |
java.lang.String |
getLabel()
Returns the label of the workflow, that was specified in the DAX.
|
java.util.Set |
getLFNs()
It returns the list of lfns referred to by the DAG.
|
java.util.Set |
getLFNs(boolean onlyInput)
Returns the list of lfns referred to by the DAG.
|
java.lang.String |
getMTime()
Returns the last modified time for the file containing the workflow
description.
|
java.lang.String |
getReleaseVersion()
Return the release version
|
WorkflowMetrics |
getWorkflowMetrics()
Returns the workflow metrics so far.
|
void |
setCount(java.lang.String count)
Set the count of the workflow, that was specified in the DAX.
|
void |
setDAXMTime(java.io.File f)
Sets the mtime (last modified time) for the DAX.
|
void |
setDAXMTime(java.lang.String time)
Sets the mtime (last modified time) for the DAX.
|
void |
setDAXVersion(java.lang.String version)
Sets the dax version
|
void |
setFlowTimestamp(java.lang.String timestamp)
Sets the flow timestamp for the workflow.
|
void |
setIndex(java.lang.String index)
Set the index of the workflow, that was specified in the DAX.
|
void |
setLabel(java.lang.String label)
Sets the label for the workflow.
|
void |
setReleaseVersion()
Grabs the release version from VDS.Properties file.
|
java.lang.String |
toString()
Returns the a textual description of the object.
|
void |
updateLFNMap(java.lang.String lfn,
java.lang.String type)
Updates the lfn map, that contains the mapping of an lfn with the type.
|
setToString, vectorToString
private static final java.lang.String DEFAULT_NAME
private java.lang.String mNameOfADag
private java.lang.String mCount
private java.lang.String mIndex
private java.lang.String mFlowID
mFlowIDName
,
mFlowTimestamp
private java.lang.String mFlowIDName
private java.lang.String mFlowTimestamp
private java.lang.String mDAXMTime
private java.lang.String mReleaseVersion
private WorkflowMetrics mWFMetrics
public java.util.TreeMap lfnMap
private java.lang.String mDAXVersion
public java.util.Set getLFNs()
String objects corresponding to the
logical filenames
public java.util.Set getLFNs(boolean onlyInput)
onlyInput
- a boolean flag indicating that you need only the input
files to the whole workflowpublic java.lang.String getLabel()
public java.lang.String getIndex()
public void setIndex(java.lang.String index)
index
- the countpublic void setCount(java.lang.String count)
count
- the countpublic java.lang.String getCount()
public java.lang.String getDAXVersion()
public java.lang.String getMTime()
public java.lang.String getFlowTimestamp()
public void setFlowTimestamp(java.lang.String timestamp)
timestamp
- the flowtimestamppublic WorkflowMetrics getWorkflowMetrics()
public void generateFlowID()
public java.lang.String getFlowID()
public void generateFlowName()
public java.lang.String getFlowName()
public void setLabel(java.lang.String label)
label
- the label to be assigned to the workflowpublic void setDAXVersion(java.lang.String version)
version
- the version of the DAXpublic void setDAXMTime(java.io.File f)
f
- the file descriptor to the DAX|PDAX file.public void setDAXMTime(java.lang.String time)
time
- iso formatted time string indicating the last modified time
of DAXpublic java.lang.String getReleaseVersion()
public void setReleaseVersion()
public void updateLFNMap(java.lang.String lfn, java.lang.String type)
lfn
- the logical file name.type
- type the type of lfn (i|o|b). usually a character.public java.lang.Object clone()
clone
in class java.lang.Object