org.apache.flink.runtime.executiongraph

Interface AccessExecution

All Known Implementing Classes:

ArchivedExecution, Execution

public interface AccessExecution

Common interface for the runtime Execution and ArchivedExecution.

Method Summary

Modifier and Type	Method and Description
TaskManagerLocation	getAssignedResourceLocation() Returns the TaskManagerLocation for this execution.
ExecutionAttemptID	getAttemptId() Returns the ExecutionAttemptID for this Execution.
int	getAttemptNumber() Returns the attempt number for this execution.
Optional<ErrorInfo>	getFailureInfo() Returns the exception that caused the job to fail.
IOMetrics	getIOMetrics()
int	getParallelSubtaskIndex() Returns the subtask index of this execution.
ExecutionState	getState() Returns the current ExecutionState for this execution.
long	getStateTimestamp(ExecutionState state) Returns the timestamp for the given ExecutionState.
long[]	getStateTimestamps() Returns the timestamps for every ExecutionState.
StringifiedAccumulatorResult[]	getUserAccumulatorsStringified() Returns the user-defined accumulators as strings.

Method Detail

getAttemptId

ExecutionAttemptID getAttemptId()

Returns the ExecutionAttemptID for this Execution.

Returns:

ExecutionAttemptID for this execution

getAttemptNumber

int getAttemptNumber()

Returns the attempt number for this execution.

Returns:

attempt number for this execution.

getStateTimestamps

long[] getStateTimestamps()

Returns the timestamps for every ExecutionState.

Returns:

timestamps for each state

getState

ExecutionState getState()

Returns the current ExecutionState for this execution.

Returns:

execution state for this execution

getAssignedResourceLocation

TaskManagerLocation getAssignedResourceLocation()

Returns the TaskManagerLocation for this execution.

Returns:

taskmanager location for this execution.

getFailureInfo

Optional<ErrorInfo> getFailureInfo()

Returns the exception that caused the job to fail. This is the first root exception that was not recoverable and triggered job failure.

Returns:

an Optional of ErrorInfo containing the Throwable and the time it was registered if an error occurred. If no error occurred an empty Optional will be returned.

getStateTimestamp

long getStateTimestamp(ExecutionState state)

Returns the timestamp for the given ExecutionState.

Parameters:

state - state for which the timestamp should be returned

Returns:

timestamp for the given state

getUserAccumulatorsStringified

StringifiedAccumulatorResult[] getUserAccumulatorsStringified()

Returns the user-defined accumulators as strings.

Returns:

user-defined accumulators as strings.

getParallelSubtaskIndex

int getParallelSubtaskIndex()

Returns the subtask index of this execution.

Returns:

subtask index of this execution.

getIOMetrics

IOMetrics getIOMetrics()