Package org.apache.flink.runtime.executiongraph

Class ArchivedExecutionVertex

java.lang.Object

org.apache.flink.runtime.executiongraph.ArchivedExecutionVertex

All Implemented Interfaces:

Serializable, AccessExecutionVertex

public class ArchivedExecutionVertex
extends Object
implements AccessExecutionVertex, Serializable

ArchivedExecutionVertex is a readonly representation of ExecutionVertex.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ArchivedExecutionVertex(int subTaskIndex, String taskNameWithSubtask, ArchivedExecution currentExecution, ExecutionHistory executionHistory)
ArchivedExecutionVertex(ExecutionVertex vertex)

Method Summary

Modifier and Type	Method	Description
TaskManagerLocation	getCurrentAssignedResourceLocation()	Returns the TaskManagerLocation for this execution vertex.
ArchivedExecution	getCurrentExecutionAttempt()	Returns the current execution for this execution vertex.
Collection<AccessExecution>	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)".

Methods inherited from class java.lang.Object

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

Constructor Detail

ArchivedExecutionVertex

public ArchivedExecutionVertex(ExecutionVertex vertex)

ArchivedExecutionVertex

@VisibleForTesting
public ArchivedExecutionVertex(int subTaskIndex,
                               String taskNameWithSubtask,
                               ArchivedExecution currentExecution,
                               ExecutionHistory executionHistory)

Method Detail

getTaskNameWithSubtaskIndex

public String getTaskNameWithSubtaskIndex()

Description copied from interface: AccessExecutionVertex

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

Specified by:

getTaskNameWithSubtaskIndex in interface AccessExecutionVertex

Returns:

name of this execution vertex

getParallelSubtaskIndex

public int getParallelSubtaskIndex()

Description copied from interface: AccessExecutionVertex

Returns the subtask index of this execution vertex.

Specified by:

getParallelSubtaskIndex in interface AccessExecutionVertex

Returns:

subtask index of this execution vertex.

getCurrentExecutionAttempt

public ArchivedExecution getCurrentExecutionAttempt()

Description copied from interface: AccessExecutionVertex

Returns the current execution for this execution vertex.

Specified by:

getCurrentExecutionAttempt in interface AccessExecutionVertex

Returns:

current execution

getCurrentExecutions

public Collection<AccessExecution> getCurrentExecutions()

Description copied from interface: AccessExecutionVertex

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

Specified by:

getCurrentExecutions in interface AccessExecutionVertex

Returns:

current executions

getExecutionState

public ExecutionState getExecutionState()

Description copied from interface: AccessExecutionVertex

Returns the current ExecutionState for this execution vertex.

Specified by:

getExecutionState in interface AccessExecutionVertex

Returns:

execution state for this execution vertex

getStateTimestamp

public long getStateTimestamp(ExecutionState state)

Description copied from interface: AccessExecutionVertex

Returns the timestamp for the given ExecutionState.

Specified by:

getStateTimestamp in interface AccessExecutionVertex

Parameters:

state - state for which the timestamp should be returned

Returns:

timestamp for the given state

getFailureInfo

public Optional<ErrorInfo> getFailureInfo()

Description copied from interface: AccessExecutionVertex

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

Specified by:

getFailureInfo in interface AccessExecutionVertex

Returns:

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

getCurrentAssignedResourceLocation

public TaskManagerLocation getCurrentAssignedResourceLocation()

Description copied from interface: AccessExecutionVertex

Returns the TaskManagerLocation for this execution vertex.

Specified by:

getCurrentAssignedResourceLocation in interface AccessExecutionVertex

Returns:

taskmanager location for this execution vertex.

getExecutionHistory

public ExecutionHistory getExecutionHistory()

Description copied from interface: AccessExecutionVertex

Returns the execution history.

Specified by:

getExecutionHistory in interface AccessExecutionVertex

Returns:

the execution history