edu.isi.pegasus.planner.classes
Modifier and Type | Field and Description |
---|---|
private Properties |
mApplicationMetrics
The application metrics that need to be forwarded
|
private String |
mBaseSubmitDirectory
The base submit directory where the files are being created.
|
private String |
mClient
The name of the client
|
private String |
mDataConfiguration
The UUID associated with the workflow.
|
private String |
mDAXPath
The path to the DAX that was planned by the workflow.
|
private double |
mDuration
The planning duration
|
private double |
mEndTime
The end time for the planning.
|
private String |
mErrorMessage
The error message to be logged
|
private int |
mExitcode
the exitcode of the planner
|
private File |
mMetricsFileInSubmitDirectory |
private NumberFormat |
mNumFormatter
The number formatter to format the run submit dir entries.
|
private String |
mPropertiesPath
The pointer to the properties file that was used.
|
private String |
mRelativeSubmitDirectory
The relative submit directory for this run.
|
private String |
mRootWorkflowUUID
The Root Workflow UUID.
|
private double |
mStartTime
The start time for the planning.
|
private String |
mType
The name of the client
|
private String |
mUser
The user who planned the workflow.
|
private String |
mVersion
The planner version
|
private String |
mVOGroup
The VOGroup to which the user belonged to.
|
private WorkflowMetrics |
mWFMetrics
The metrics about the workflow.
|
private String |
mWorkflowUUID
The UUID associated with the workflow.
|
Constructor and Description |
---|
PlannerMetrics()
The default metrics.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Properties |
getApplicationMetrics()
Returns the application specific metrics that will be forwarded to the
server
|
String |
getBaseSubmitDirectory()
Returns the path to the base submit directory.
|
String |
getDataConfiguration()
Returns the data configuration
|
String |
getDAX()
Sets the path to the DAX.
|
double |
getDuration()
Returns the duration for the planning
|
double |
getEndTime()
Returns the end time for the planning operation as epoch with
millisecond precision
|
String |
getErrorMessage()
Returns the error message that we want to log
|
int |
getExitcode()
Returns the exitcode for the planner
|
File |
getMetricsFileLocationInSubmitDirectory()
Sets the metrics file location in the submit directory
|
String |
getMetricsType()
Returns the metric type
|
String |
getProperties()
Returns the path to the properties file for the run.
|
String |
getRelativeSubmitDirectory()
Returns the path to the relative submit directory.
|
String |
getRootWorkflowUUID()
Returns the UUID for the Root workflow
|
double |
getStartTime()
Returns the start time for the planning operation as epoch with
millisecond precision
|
String |
getUser()
Returns the username.
|
String |
getVOGroup()
Returns the VO Group.
|
WorkflowMetrics |
getWorkflowMetrics()
Returns the workflow metrics.
|
String |
getWorkflowUUID()
Returns the UUID for the workflow
|
void |
setApplicationMetrics(PegasusProperties properties)
Sets the app metrics that need to be forwarded.
|
void |
setApplicationMetrics(Properties properties)
Sets the app metrics that need to be forwarded.
|
void |
setBaseSubmitDirectory(String base)
Sets the path to the base submit directory.
|
void |
setDataConfiguration(String configuration)
The data configuration
|
void |
setDAX(String path)
Sets the path to the DAX.
|
void |
setDuration(double duration)
Sets the user.
|
void |
setEndTime(Date end)
Set the end time for the planning operation.
|
void |
setEndTime(double end)
Set the end time for the planning operation.
|
void |
setErrorMessage(String error)
Set the error message that we want to log
|
void |
setExitcode(int exitcode)
Sets the exitcode for the planner.
|
void |
setMetricsFileLocationInSubmitDirectory(File f)
Sets the metrics file location in the submit directory
|
void |
setMetricsType(String type)
Sets the metrics
|
void |
setMetricsTypeToError()
Convenience setter method
|
void |
setProperties(String path)
Sets the path to the properties file for the run.
|
void |
setRelativeSubmitDirectory(String relative)
Sets the path to the submit directory relative to the base.
|
void |
setRootWorkflowUUID(String uuid)
Sets the root UUID for the workflow
|
void |
setStartTime(Date start)
Set the start time for the planning operation.
|
void |
setStartTime(double start)
Set the start time for the planning operation.
|
void |
setUser(String user)
Sets the user.
|
void |
setVOGroup(String group)
Sets the vo group
|
void |
setWorkflowMetrics(WorkflowMetrics metrics)
Sets the workflow metrics.
|
void |
setWorkflowUUID(String uuid)
Sets the UUID for the workflow
|
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 String mBaseSubmitDirectory
private String mRelativeSubmitDirectory
private File mMetricsFileInSubmitDirectory
private String mDAXPath
private String mPropertiesPath
private String mUser
private String mVOGroup
private NumberFormat mNumFormatter
private final String mClient
private final String mVersion
private String mType
private double mStartTime
private double mEndTime
private double mDuration
private int mExitcode
private String mRootWorkflowUUID
private String mWorkflowUUID
private String mDataConfiguration
private WorkflowMetrics mWFMetrics
private Properties mApplicationMetrics
private String mErrorMessage
public String getRootWorkflowUUID()
public void setRootWorkflowUUID(String uuid)
uuid
- the UUID of the workflowpublic String getWorkflowUUID()
public void setWorkflowUUID(String uuid)
uuid
- the UUID of the workflowpublic WorkflowMetrics getWorkflowMetrics()
public void setWorkflowMetrics(WorkflowMetrics metrics)
metrics
- the workflow metrics.public void setApplicationMetrics(Properties properties)
metrics
- the application metricspublic void setApplicationMetrics(PegasusProperties properties)
metrics
- the application metricspublic Properties getApplicationMetrics()
public String getUser()
public void setUser(String user)
user
- the user.public void setMetricsType(String type)
type
- the metrics typepublic void setMetricsTypeToError()
type
- the metrics typepublic String getMetricsType()
public void setVOGroup(String group)
group
- the vo group.public String getVOGroup()
public void setProperties(String path)
path
- the path to the properties file.public String getProperties()
public void setBaseSubmitDirectory(String base)
base
- the path to the base submit directory.public String getBaseSubmitDirectory()
public void setRelativeSubmitDirectory(String relative)
relative
- the relative path from the base submit directory.public String getRelativeSubmitDirectory()
public void setMetricsFileLocationInSubmitDirectory(File f)
f
- the file pointing to the metrics filepublic File getMetricsFileLocationInSubmitDirectory()
public void setDAX(String path)
path
- the path to the DAX file.public String getDAX()
public void setDataConfiguration(String configuration)
configuration
- the data configurationpublic String getDataConfiguration()
public void setStartTime(Date start)
start
- the start time.public void setStartTime(double start)
start
- the start time.public double getStartTime()
public void setEndTime(Date end)
end
- the end time.public void setEndTime(double end)
end
- the end time.public double getEndTime()
public double getDuration()
public void setDuration(double duration)
duration
- the durationpublic int getExitcode()
public void setExitcode(int exitcode)
exitcode
- the exitcodepublic void setErrorMessage(String error)
error
- errorpublic String getErrorMessage()
public String toJson()
public String toPrettyJson()
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.