Package org.apache.nemo.runtime.executor

Class TaskStateManager

java.lang.Object

org.apache.nemo.runtime.executor.TaskStateManager

public final class TaskStateManager
extends java.lang.Object

Manages the states related to a task. The methods of this class are synchronized.

Constructor Summary

Constructors

Constructor	Description
TaskStateManager(Task task, java.lang.String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)

Method Summary

Modifier and Type	Method	Description
void	getCurrentTaskExecutionState()
void	onTaskStateChanged(TaskState.State newState, java.util.Optional<java.lang.String> vertexPutOnHold, java.util.Optional<TaskState.RecoverableTaskFailureCause> cause)	Updates the state of the task.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskStateManager

public TaskStateManager(Task task,
                        java.lang.String executorId,
                        PersistentConnectionToMasterMap persistentConnectionToMasterMap,
                        MetricMessageSender metricMessageSender)

Method Detail

onTaskStateChanged

public void onTaskStateChanged(TaskState.State newState,
                               java.util.Optional<java.lang.String> vertexPutOnHold,
                               java.util.Optional<TaskState.RecoverableTaskFailureCause> cause)

Updates the state of the task.

Parameters:

newState - of the task.

vertexPutOnHold - the vertex put on hold.

cause - only provided as non-empty upon recoverable failures.

getCurrentTaskExecutionState

public void getCurrentTaskExecutionState()