ds.granules.exchange

Class TaskLifecycleMetricsReader

java.lang.Object

ds.granules.exchange.TaskLifecycleMetricsReader

All Implemented Interfaces:

TaskLifecycleMetrics

public class TaskLifecycleMetricsReader
extends Object
implements TaskLifecycleMetrics

Field Summary

Fields inherited from interface ds.granules.scheduler.TaskLifecycleMetrics

ABNORMAL_TERMINATION, ABORTED, COMPLETE, EXECUTING, INITIALIZED, INITIALIZING, NOT_SET, QUEUED_FOR_EXECUTION, READY, WAITING_FOR_DATA

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TaskLifecycleMetricsReader(byte[] marshalledBytes)

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskLifecycleMetricsReader

protected TaskLifecycleMetricsReader(byte[] marshalledBytes)
                              throws IOException

Throws:

IOException

Method Detail

getInstanceIdentifier

public String getInstanceIdentifier()

Description copied from interface: TaskLifecycleMetrics

Retrieve the instance identifier of the operation that was encapsulated within a Task. This will allow us to determine which taskId was connected to which instanceId.

Specified by:

getInstanceIdentifier in interface TaskLifecycleMetrics

Returns:

The instance identifier of the operation.

getArrivalTime

public long getArrivalTime()

Description copied from interface: TaskLifecycleMetrics

Retrieve the time at which the operation arrived at this node.

Specified by:

getArrivalTime in interface TaskLifecycleMetrics

Returns:

The arrival time in milliseconds.

getCPUBoundTime

public long getCPUBoundTime()

Description copied from interface: TaskLifecycleMetrics

Retrieve the CPU-bound time of the computation.

Specified by:

getCPUBoundTime in interface TaskLifecycleMetrics

Returns:

The CPU-bound time in milliseconds.

getCompletionTime

public long getCompletionTime()

Description copied from interface: TaskLifecycleMetrics

Retrieve the time at which this task was completed

Specified by:

getCompletionTime in interface TaskLifecycleMetrics

Returns:

The completion time in milliseconds.

getNumberofIterationsSoFar

public int getNumberofIterationsSoFar()

Description copied from interface: TaskLifecycleMetrics

Retrieve the number of iterations performed for the operation so far

Specified by:

getNumberofIterationsSoFar in interface TaskLifecycleMetrics

Returns:

The number of times that the computation has been inovoked so far.

getStartTime

public long getStartTime()

Description copied from interface: TaskLifecycleMetrics

Retrieve the time this operation was first launched

Specified by:

getStartTime in interface TaskLifecycleMetrics

Returns:

The startTime in milliseconds.

getTimeResidentInMemory

public long getTimeResidentInMemory()

Description copied from interface: TaskLifecycleMetrics

Retrieve the time this operation spent residing in memory

Specified by:

getTimeResidentInMemory in interface TaskLifecycleMetrics

Returns:

The memory-resident time in milliseconds.

getExecutionStatus

public int getExecutionStatus()

Description copied from interface: TaskLifecycleMetrics

Retrieve the execution status associated with the operation.

Specified by:

getExecutionStatus in interface TaskLifecycleMetrics

Returns:

The execution status for the task

getTaskCompletionInfo

public String getTaskCompletionInfo()

Description copied from interface: TaskLifecycleMetrics

Retrieve information about the completion of a task. In the case of errors and aborts of executions this will include information about why a task was prematurely terminated.

Specified by:

getTaskCompletionInfo in interface TaskLifecycleMetrics

Returns:

The task completion information as a String

getBytes

public byte[] getBytes()
                throws IOException

Description copied from interface: TaskLifecycleMetrics

Create the serialized representation of this class.

Specified by:

getBytes in interface TaskLifecycleMetrics

Returns:

The byte[] stream for this object.

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object