org.apache.reef.runtime.common.driver.evaluator.pojos

Class TaskStatusPOJO

java.lang.Object

org.apache.reef.runtime.common.driver.evaluator.pojos.TaskStatusPOJO

public final class TaskStatusPOJO
extends Object

DriverSide representation of TaskStatusProto.

Constructor Summary

Constructors

Constructor and Description
TaskStatusPOJO(ReefServiceProtos.TaskStatusProto proto, long sequenceNumber)

Method Summary

Modifier and Type	Method and Description
String	getContextId()
byte[]	getResult()
State	getState()
String	getTaskId()
List<TaskMessagePOJO>	getTaskMessageList()
boolean	hasResult()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskStatusPOJO

public TaskStatusPOJO(ReefServiceProtos.TaskStatusProto proto,
                      long sequenceNumber)

Method Detail

getTaskMessageList

public List<TaskMessagePOJO> getTaskMessageList()

Returns:

a list of messages sent by a task

hasResult

public boolean hasResult()

Returns:

true, if a completed task returned a non-null value in the 'return' statement

getResult

public byte[] getResult()

Returns:

serialized result that a completed task returned to the Driver

getTaskId

public String getTaskId()

Returns:

the id of a task

getContextId

public String getContextId()

Returns:

the id of a context that this task runs within

getState

public State getState()

Returns:

current State of a task