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

Packages that use TaskState.RecoverableTaskFailureCause

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

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

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

Modifier and Type	Method	Description
static TaskState.RecoverableTaskFailureCause	MessageUtils.convertFailureCause(ControlMessage.RecoverableFailureCause cause)

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

Modifier and Type	Method	Description
static ControlMessage.RecoverableFailureCause	MessageUtils.convertFailureCause(TaskState.RecoverableTaskFailureCause cause)

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

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

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

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

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

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)