org.apache.flink.runtime.executiongraph

Interface AccessExecutionVertex

All Known Implementing Classes:

ArchivedExecutionVertex, ExecutionVertex, SpeculativeExecutionVertex

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.
<T extends AccessExecution> Collection<T>	getCurrentExecutions() Returns the current executions for this execution vertex.
ExecutionHistory	getExecutionHistory() Returns the execution history.
ExecutionState	getExecutionState() Returns the current ExecutionState for this execution vertex.
Optional<ErrorInfo>	getFailureInfo() Returns the exception that caused the job to fail.
int	getParallelSubtaskIndex() Returns the subtask index of this execution vertex.
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

getCurrentExecutions

<T extends AccessExecution> Collection<T> getCurrentExecutions()

Returns the current executions for this execution vertex. The returned collection must contain the current execution attempt.

Returns:

current executions

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

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:

failure exception wrapped in an Optional of ErrorInfo, or an empty Optional if no exception was caught.

getCurrentAssignedResourceLocation

TaskManagerLocation getCurrentAssignedResourceLocation()

Returns the TaskManagerLocation for this execution vertex.

Returns:

taskmanager location for this execution vertex.

getExecutionHistory

ExecutionHistory getExecutionHistory()

Returns the execution history.

Returns:

the execution history