Uses of Class
org.apache.nemo.runtime.common.state.TaskState.State

Packages that use TaskState.State

Package	Description
org.apache.nemo.runtime.common.message
org.apache.nemo.runtime.common.metric
org.apache.nemo.runtime.common.state
org.apache.nemo.runtime.executor
org.apache.nemo.runtime.master
org.apache.nemo.runtime.master.scheduler

Uses of TaskState.State in org.apache.nemo.runtime.common.message

Methods in org.apache.nemo.runtime.common.message that return TaskState.State

Modifier and Type	Method	Description
static TaskState.State	MessageUtils.convertTaskState(ControlMessage.TaskStateFromExecutor state)

Methods in org.apache.nemo.runtime.common.message with parameters of type TaskState.State

Modifier and Type	Method	Description
static ControlMessage.TaskStateFromExecutor	MessageUtils.convertState(TaskState.State state)

Uses of TaskState.State in org.apache.nemo.runtime.common.metric

Methods in org.apache.nemo.runtime.common.metric that return types with arguments of type TaskState.State

Modifier and Type	Method	Description
java.util.List<StateTransitionEvent<TaskState.State>>	TaskMetric.getStateTransitionEvents()	Method related to state transition events.

Methods in org.apache.nemo.runtime.common.metric with parameters of type TaskState.State

Modifier and Type	Method	Description
void	TaskMetric.addEvent(TaskState.State prevState, TaskState.State newState)

Uses of TaskState.State in org.apache.nemo.runtime.common.state

Methods in org.apache.nemo.runtime.common.state that return TaskState.State

Modifier and Type	Method	Description
static TaskState.State	TaskState.State.valueOf(java.lang.String name)	Returns the enum constant of this type with the specified name.
static TaskState.State[]	TaskState.State.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Uses of TaskState.State in org.apache.nemo.runtime.executor

Methods in org.apache.nemo.runtime.executor with parameters of type TaskState.State

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

Uses of TaskState.State in org.apache.nemo.runtime.master

Methods in org.apache.nemo.runtime.master that return TaskState.State

Modifier and Type	Method	Description
TaskState.State	PlanStateManager.getTaskState(java.lang.String taskId)

Methods in org.apache.nemo.runtime.master that return types with arguments of type TaskState.State

Modifier and Type	Method	Description
java.util.Map<java.lang.String,TaskState.State>	PlanStateManager.getAllTaskAttemptIdsToItsState()

Methods in org.apache.nemo.runtime.master with parameters of type TaskState.State

Modifier and Type	Method	Description
void	PlanStateManager.onTaskStateChanged(java.lang.String taskId, TaskState.State newTaskState)	Updates the state of a task.

Uses of TaskState.State in org.apache.nemo.runtime.master.scheduler

Methods in org.apache.nemo.runtime.master.scheduler with parameters of type TaskState.State

Modifier and Type	Method	Description
void	BatchScheduler.onTaskStateReportFromExecutor(java.lang.String executorId, java.lang.String taskId, int taskAttemptIndex, TaskState.State newState, java.lang.String vertexPutOnHold, TaskState.RecoverableTaskFailureCause failureCause)	Handles task state transition notifications sent from executors.
void	Scheduler.onTaskStateReportFromExecutor(java.lang.String executorId, java.lang.String taskId, int attemptIdx, TaskState.State newState, java.lang.String taskPutOnHold, TaskState.RecoverableTaskFailureCause failureCause)	Called when a Task's execution state changes.
void	SimulationScheduler.onTaskStateReportFromExecutor(java.lang.String executorId, java.lang.String taskId, int attemptIdx, TaskState.State newState, java.lang.String taskPutOnHold, TaskState.RecoverableTaskFailureCause failureCause)
void	StreamingScheduler.onTaskStateReportFromExecutor(java.lang.String executorId, java.lang.String taskId, int taskAttemptIndex, TaskState.State newState, java.lang.String vertexPutOnHold, TaskState.RecoverableTaskFailureCause failureCause)