org.apache.reef.runtime.common.driver.task

Class TaskRepresenter

java.lang.Object

org.apache.reef.runtime.common.driver.task.TaskRepresenter

public final class TaskRepresenter
extends Object

Represents a Task on the Driver.

Constructor Summary

Constructors

Constructor and Description
TaskRepresenter(String taskId, EvaluatorContext context, EvaluatorMessageDispatcher messageDispatcher, EvaluatorManager evaluatorManager, ExceptionCodec exceptionCodec, DriverRestartManager driverRestartManager)

Method Summary

Methods

Modifier and Type	Method and Description
String	getId()
boolean	isClosable()
boolean	isNotRunning()
void	onTaskStatusMessage(TaskStatusPOJO taskStatus)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskRepresenter

public TaskRepresenter(String taskId,
               EvaluatorContext context,
               EvaluatorMessageDispatcher messageDispatcher,
               EvaluatorManager evaluatorManager,
               ExceptionCodec exceptionCodec,
               DriverRestartManager driverRestartManager)

Method Detail

onTaskStatusMessage

public void onTaskStatusMessage(TaskStatusPOJO taskStatus)

getId

public String getId()

isNotRunning

public boolean isNotRunning()

Returns:

true, if this task is in any other state but RUNNING.

isClosable

public boolean isClosable()

Returns:

true, if this task is in INIT or RUNNING status.