Modifier and Type | Field and Description |
---|---|
private static String |
DEFAULT_NAME
The default name for the ADag object, if not supplied in the DAX.
|
TreeMap |
lfnMap
Contains a unique ordered listing of the logical names referred
to by the dag.
|
private 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 String |
mDAXMTime
Keeps the last modified time of the DAX.
|
private String |
mDAXVersion
The DAX Version
|
private String |
mFlowID
It is a unique identifier identifying the concrete DAG generated by Pegasus.
|
private String |
mFlowIDName
It is the name of the dag as generated by Chimera in the dax.
|
private String |
mFlowTimestamp
The ISO timestamp corresponding to the time when Pegasus is invoked for a
dax.
|
private String |
mIndex
Refers to the number of the Dag.
|
private String |
mNameOfADag
The name of the Abstract Dag taken from the adag element of the DAX
generated by the Abstract Planner.
|
private 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 |
---|---|
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.
|
String |
getCount()
Returns the count of the workflow, that was specified in the DAX.
|
String |
getDAXVersion()
Returns the dax version
|
String |
getFlowID()
Returns the generated flow ID for the workflow.
|
String |
getFlowName()
Returns the flow name
|
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.
|
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.
|
String |
getReleaseVersion()
Return the release version
|
WorkflowMetrics |
getWorkflowMetrics()
Returns the workflow metrics so far.
|
void |
setCount(String count)
Set the count of the workflow, that was specified in the DAX.
|
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 |
setIndex(String index)
Set the index of the workflow, that was specified in the DAX.
|
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
private String mNameOfADag
private String mCount
private String mIndex
private String mFlowID
mFlowIDName
,
mFlowTimestamp
private String mFlowIDName
private String mFlowTimestamp
private String mDAXMTime
private String mReleaseVersion
private WorkflowMetrics mWFMetrics
public TreeMap lfnMap
private String mDAXVersion
public 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 void setIndex(String index)
index
- the countpublic void setCount(String count)
count
- the countpublic String getCount()
public String getDAXVersion()
public String getMTime()
public String getFlowTimestamp()
public void setFlowTimestamp(String timestamp)
timestamp
- the flowtimestamppublic WorkflowMetrics getWorkflowMetrics()
public void generateFlowID()
public String getFlowID()
public void generateFlowName()
public String getFlowName()
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 String getReleaseVersion()
public void setReleaseVersion()
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()