public class TaskLifecycleMetricsReader extends Object implements TaskLifecycleMetrics
ABNORMAL_TERMINATION, ABORTED, COMPLETE, EXECUTING, INITIALIZED, INITIALIZING, NOT_SET, QUEUED_FOR_EXECUTION, READY, WAITING_FOR_DATA
Modifier | Constructor and Description |
---|---|
protected |
TaskLifecycleMetricsReader(byte[] marshalledBytes) |
Modifier and Type | Method and Description |
---|---|
long |
getArrivalTime()
Retrieve the time at which the operation arrived at this node.
|
byte[] |
getBytes()
Create the serialized representation of this class.
|
long |
getCompletionTime()
Retrieve the time at which this task was completed
|
long |
getCPUBoundTime()
Retrieve the CPU-bound time of the computation.
|
int |
getExecutionStatus()
Retrieve the execution status associated with the operation.
|
String |
getInstanceIdentifier()
Retrieve the instance identifier of the operation that was encapsulated
within a Task.
|
int |
getNumberofIterationsSoFar()
Retrieve the number of iterations performed for the operation so far
|
long |
getStartTime()
Retrieve the time this operation was first launched
|
String |
getTaskCompletionInfo()
Retrieve information about the completion of a task.
|
long |
getTimeResidentInMemory()
Retrieve the time this operation spent residing in memory
|
String |
toString() |
protected TaskLifecycleMetricsReader(byte[] marshalledBytes) throws IOException
IOException
public String getInstanceIdentifier()
TaskLifecycleMetrics
getInstanceIdentifier
in interface TaskLifecycleMetrics
public long getArrivalTime()
TaskLifecycleMetrics
getArrivalTime
in interface TaskLifecycleMetrics
public long getCPUBoundTime()
TaskLifecycleMetrics
getCPUBoundTime
in interface TaskLifecycleMetrics
public long getCompletionTime()
TaskLifecycleMetrics
getCompletionTime
in interface TaskLifecycleMetrics
public int getNumberofIterationsSoFar()
TaskLifecycleMetrics
getNumberofIterationsSoFar
in interface TaskLifecycleMetrics
public long getStartTime()
TaskLifecycleMetrics
getStartTime
in interface TaskLifecycleMetrics
public long getTimeResidentInMemory()
TaskLifecycleMetrics
getTimeResidentInMemory
in interface TaskLifecycleMetrics
public int getExecutionStatus()
TaskLifecycleMetrics
getExecutionStatus
in interface TaskLifecycleMetrics
public String getTaskCompletionInfo()
TaskLifecycleMetrics
getTaskCompletionInfo
in interface TaskLifecycleMetrics
public byte[] getBytes() throws IOException
TaskLifecycleMetrics
getBytes
in interface TaskLifecycleMetrics
IOException
Copyright © 2015. All rights reserved.