edu.snu.coral.runtime.executor

Class TaskGroupStateManager

java.lang.Object

edu.snu.coral.runtime.executor.TaskGroupStateManager

public final class TaskGroupStateManager
extends Object

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

Constructor Summary

Constructors

Constructor and Description
TaskGroupStateManager(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)

Method Summary

Modifier and Type	Method and Description
void	getCurrentTaskGroupExecutionState()
void	onTaskGroupStateChanged(TaskGroupState.State newState, Optional<String> taskPutOnHold, Optional<TaskGroupState.RecoverableFailureCause> cause) Updates the state of the task group.
void	onTaskStateChanged(String physicalTaskId, TaskState.State newState, Optional<TaskGroupState.RecoverableFailureCause> cause) Updates the state of a task.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskGroupStateManager

public TaskGroupStateManager(ScheduledTaskGroup scheduledTaskGroup,
                             DAG<Task,RuntimeEdge<Task>> taskGroupDag,
                             String executorId,
                             PersistentConnectionToMasterMap persistentConnectionToMasterMap,
                             MetricMessageSender metricMessageSender)

Method Detail

onTaskGroupStateChanged

public void onTaskGroupStateChanged(TaskGroupState.State newState,
                                    Optional<String> taskPutOnHold,
                                    Optional<TaskGroupState.RecoverableFailureCause> cause)

Updates the state of the task group.

Parameters:

newState - of the task group.

taskPutOnHold - the logical ID of the tasks put on hold, empty otherwise.

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

onTaskStateChanged

public void onTaskStateChanged(String physicalTaskId,
                               TaskState.State newState,
                               Optional<TaskGroupState.RecoverableFailureCause> cause)

Updates the state of a task. Task state changes only occur in executor.

Parameters:

physicalTaskId - of the task.

newState - of the task.

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

getCurrentTaskGroupExecutionState

public void getCurrentTaskGroupExecutionState()