org.apache.flink.runtime.executiongraph

Interface AccessExecutionVertex

All Known Implementing Classes:

ArchivedExecutionVertex, ExecutionVertex

public interface AccessExecutionVertex

Common interface for the runtime ExecutionVertex and ArchivedExecutionVertex.

Method Summary

Modifier and Type	Method and Description
TaskManagerLocation	getCurrentAssignedResourceLocation() Returns the TaskManagerLocation for this execution vertex.
AccessExecution	getCurrentExecutionAttempt() Returns the current execution for this execution vertex.
ExecutionState	getExecutionState() Returns the current ExecutionState for this execution vertex.
String	getFailureCauseAsString() Returns the exception that caused the job to fail.
int	getParallelSubtaskIndex() Returns the subtask index of this execution vertex.
AccessExecution	getPriorExecutionAttempt(int attemptNumber) Returns the execution for the given attempt number.
long	getStateTimestamp(ExecutionState state) Returns the timestamp for the given ExecutionState.
String	getTaskNameWithSubtaskIndex() Returns the name of this execution vertex in the format "myTask (2/7)".

Method Detail

getTaskNameWithSubtaskIndex

String getTaskNameWithSubtaskIndex()

Returns the name of this execution vertex in the format "myTask (2/7)".

Returns:

name of this execution vertex

getParallelSubtaskIndex

int getParallelSubtaskIndex()

Returns the subtask index of this execution vertex.

Returns:

subtask index of this execution vertex.

getCurrentExecutionAttempt

AccessExecution getCurrentExecutionAttempt()

Returns the current execution for this execution vertex.

Returns:

current execution

getExecutionState

ExecutionState getExecutionState()

Returns the current ExecutionState for this execution vertex.

Returns:

execution state for this execution vertex

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

getFailureCauseAsString

String getFailureCauseAsString()

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

Returns:

failure exception as a string, or "(null)"

getCurrentAssignedResourceLocation

TaskManagerLocation getCurrentAssignedResourceLocation()

Returns the TaskManagerLocation for this execution vertex.

Returns:

taskmanager location for this execution vertex.

getPriorExecutionAttempt

@Nullable
AccessExecution getPriorExecutionAttempt(int attemptNumber)

Returns the execution for the given attempt number.

Parameters:

attemptNumber - attempt number of execution to be returned

Returns:

execution for the given attempt number