org.apache.flink.runtime.executiongraph

Class ArchivedExecution

java.lang.Object

org.apache.flink.runtime.executiongraph.ArchivedExecution

All Implemented Interfaces:

Serializable, AccessExecution

public class ArchivedExecution
extends Object
implements AccessExecution, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ArchivedExecution(Execution execution)
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators, IOMetrics ioMetrics, ExecutionAttemptID attemptId, int attemptNumber, ExecutionState state, String failureCause, TaskManagerLocation assignedResourceLocation, AllocationID assignedAllocationID, int parallelSubtaskIndex, long[] stateTimestamps)

Method Summary

Modifier and Type	Method and Description
AllocationID	getAssignedAllocationID()
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.
String	getFailureCauseAsString() 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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ArchivedExecution

public ArchivedExecution(Execution execution)

ArchivedExecution

public ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
                         IOMetrics ioMetrics,
                         ExecutionAttemptID attemptId,
                         int attemptNumber,
                         ExecutionState state,
                         String failureCause,
                         TaskManagerLocation assignedResourceLocation,
                         AllocationID assignedAllocationID,
                         int parallelSubtaskIndex,
                         long[] stateTimestamps)

Method Detail

getAttemptId

public ExecutionAttemptID getAttemptId()

Description copied from interface: AccessExecution

Returns the ExecutionAttemptID for this Execution.

Specified by:

getAttemptId in interface AccessExecution

Returns:

ExecutionAttemptID for this execution

getAttemptNumber

public int getAttemptNumber()

Description copied from interface: AccessExecution

Returns the attempt number for this execution.

Specified by:

getAttemptNumber in interface AccessExecution

Returns:

attempt number for this execution.

getStateTimestamps

public long[] getStateTimestamps()

Description copied from interface: AccessExecution

Returns the timestamps for every ExecutionState.

Specified by:

getStateTimestamps in interface AccessExecution

Returns:

timestamps for each state

getState

public ExecutionState getState()

Description copied from interface: AccessExecution

Returns the current ExecutionState for this execution.

Specified by:

getState in interface AccessExecution

Returns:

execution state for this execution

getAssignedResourceLocation

public TaskManagerLocation getAssignedResourceLocation()

Description copied from interface: AccessExecution

Returns the TaskManagerLocation for this execution.

Specified by:

getAssignedResourceLocation in interface AccessExecution

Returns:

taskmanager location for this execution.

getAssignedAllocationID

public AllocationID getAssignedAllocationID()

getFailureCauseAsString

public String getFailureCauseAsString()

Description copied from interface: AccessExecution

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:

getFailureCauseAsString in interface AccessExecution

Returns:

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

getStateTimestamp

public long getStateTimestamp(ExecutionState state)

Description copied from interface: AccessExecution

Returns the timestamp for the given ExecutionState.

Specified by:

getStateTimestamp in interface AccessExecution

Parameters:

state - state for which the timestamp should be returned

Returns:

timestamp for the given state

getUserAccumulatorsStringified

public StringifiedAccumulatorResult[] getUserAccumulatorsStringified()

Description copied from interface: AccessExecution

Returns the user-defined accumulators as strings.

Specified by:

getUserAccumulatorsStringified in interface AccessExecution

Returns:

user-defined accumulators as strings.

getParallelSubtaskIndex

public int getParallelSubtaskIndex()

Description copied from interface: AccessExecution

Returns the subtask index of this execution.

Specified by:

getParallelSubtaskIndex in interface AccessExecution

Returns:

subtask index of this execution.

getIOMetrics

public IOMetrics getIOMetrics()

Specified by:

getIOMetrics in interface AccessExecution