edu.isi.pegasus.planner.classes
Modifier and Type | Field and Description |
---|---|
private String |
mDAXLabel
The label of the dax.
|
private boolean |
mLockTaskMetrics
A boolean indicating whether to update task metrics
|
private int |
mNumChmodJobs |
private int |
mNumCleanupJobs
The number of cleanup jobs.
|
private int |
mNumClusteredJobs
The number of clustered compute jobs.
|
private int |
mNumComputeJobs
The number of compute jobs.
|
private int |
mNumComputeTasks
The number of compute tasks in the DAX
|
private int |
mNumCreateDirJobs
The number of create dir jobs.
|
private int |
mNumDAGJobs
The number of DAG jobs in the workflow
|
private int |
mNumDAGTasks
The number of DAG tasks in the DAX.
|
private int |
mNumDAXJobs
The number of dax jobs in the workflow
|
private int |
mNumDAXTasks
The number of DAX tasks in the DAX
|
private int |
mNumInterTxJobs
The number of inter-site transfer jobs.
|
private int |
mNumRegJobs
The number of registration jobs.
|
private int |
mNumSITxJobs
The number of stage in transfer jobs.
|
private int |
mNumSOTxJobs
The number of stage-out transfer jobs.
|
private int |
mNumTotalJobs
The total number of jobs in the executable workflow.
|
private int |
mNumTotalTasks
The total number of tasks in the executable workflow.
|
Constructor and Description |
---|
WorkflowMetrics()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
append(StringBuffer buffer,
String key,
int value)
Appends a key=value pair to the StringBuffer.
|
protected void |
append(StringBuffer buffer,
String key,
String value)
Appends a key=value pair to the StringBuffer.
|
Object |
clone()
Returns the clone of the object.
|
void |
decrement(Job job)
Decrement the metrics when on the basis of type of job being removed
|
private void |
decrementJobMetrics(Job job)
Decrement the metrics when on the basis of type of job.
|
private void |
decrementTaskMetrics(Job job)
Decrement the task metrics when on the basis of type of job.
|
String |
getLabel()
Returns the DAXlabel.
|
void |
increment(Job job)
Increment the metrics when on the basis of type of job.
|
private void |
incrementJobMetrics(Job job)
Increment the metrics when on the basis of type of job.
|
private void |
incrementTaskMetrics(Job job)
Increment the metrics when on the basis of type of job.
|
void |
lockTaskMetrics(boolean lock)
Sets the lock task metrics parameters.
|
void |
reset(boolean resetTaskMetrics)
Resets the internal counters to zero.
|
void |
setLabel(String label)
Sets the DAXlabel.
|
String |
toJson()
Converts the planner metrics to JSON
|
String |
toPrettyJson()
Converts the planner metrics to JSON
|
String |
toString()
Returns a textual description of the object.
|
setToString, vectorToString
private int mNumComputeTasks
private int mNumDAXTasks
private int mNumDAGTasks
private int mNumTotalTasks
private int mNumComputeJobs
private int mNumClusteredJobs
private int mNumSITxJobs
private int mNumSOTxJobs
private int mNumInterTxJobs
private int mNumRegJobs
private int mNumCleanupJobs
private int mNumCreateDirJobs
private int mNumDAXJobs
private int mNumDAGJobs
private int mNumChmodJobs
private int mNumTotalJobs
private String mDAXLabel
private transient boolean mLockTaskMetrics
public final void reset(boolean resetTaskMetrics)
resetTaskMetrics
- whether to reset task metrics or notpublic void setLabel(String label)
label
- the dax labelpublic String getLabel()
public void lockTaskMetrics(boolean lock)
lock
- the boolean parameterpublic void increment(Job job)
job
- the job being added.private void incrementTaskMetrics(Job job)
job
- the job being added.private void incrementJobMetrics(Job job)
job
- the job being added.public void decrement(Job job)
job
- the job being added.private void decrementJobMetrics(Job job)
job
- the job being removed.private void decrementTaskMetrics(Job job)
job
- the job being removed.public String toString()
protected void append(StringBuffer buffer, String key, String value)
buffer
- the StringBuffer that is to be appended to.key
- the key.value
- the value.protected void append(StringBuffer buffer, String key, int value)
buffer
- the StringBuffer that is to be appended to.key
- the key.value
- the value.public String toJson()
public String toPrettyJson()