Package org.apache.flink.runtime.executiongraph

Class TaskExecutionStateTransition

java.lang.Object

org.apache.flink.runtime.executiongraph.TaskExecutionStateTransition

public class TaskExecutionStateTransition
extends Object

Wraps TaskExecutionState, along with actions to take if it is FAILED state.

Constructor Summary

Constructors

Constructor	Description
TaskExecutionStateTransition(TaskExecutionState taskExecutionState)
TaskExecutionStateTransition(TaskExecutionState taskExecutionState, boolean cancelTask, boolean releasePartitions)

Method Summary

Modifier and Type	Method	Description
AccumulatorSnapshot	getAccumulators()
boolean	getCancelTask()
Throwable	getError(ClassLoader userCodeClassloader)
ExecutionState	getExecutionState()
ExecutionAttemptID	getID()
IOMetrics	getIOMetrics()
boolean	getReleasePartitions()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutionStateTransition

public TaskExecutionStateTransition(TaskExecutionState taskExecutionState)

TaskExecutionStateTransition

public TaskExecutionStateTransition(TaskExecutionState taskExecutionState,
                                    boolean cancelTask,
                                    boolean releasePartitions)

Method Detail

getError

public Throwable getError(ClassLoader userCodeClassloader)

getID

public ExecutionAttemptID getID()

getExecutionState

public ExecutionState getExecutionState()

getAccumulators

public AccumulatorSnapshot getAccumulators()

getIOMetrics

public IOMetrics getIOMetrics()

getCancelTask

public boolean getCancelTask()

getReleasePartitions

public boolean getReleasePartitions()