Interface AccessExecution
-
- All Known Implementing Classes:
ArchivedExecution
,Execution
public interface AccessExecution
Common interface for the runtimeExecution
andArchivedExecution
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description TaskManagerLocation
getAssignedResourceLocation()
Returns theTaskManagerLocation
for this execution.ExecutionAttemptID
getAttemptId()
Returns theExecutionAttemptID
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 currentExecutionState
for this execution.long
getStateEndTimestamp(ExecutionState state)
Returns the end timestamp for the givenExecutionState
.long[]
getStateEndTimestamps()
Returns the end timestamps for everyExecutionState
.long
getStateTimestamp(ExecutionState state)
Returns the timestamp for the givenExecutionState
.long[]
getStateTimestamps()
Returns the timestamps for everyExecutionState
.StringifiedAccumulatorResult[]
getUserAccumulatorsStringified()
Returns the user-defined accumulators as strings.
-
-
-
Method Detail
-
getAttemptId
ExecutionAttemptID getAttemptId()
Returns theExecutionAttemptID
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 everyExecutionState
.- Returns:
- timestamps for each state
-
getStateEndTimestamps
long[] getStateEndTimestamps()
Returns the end timestamps for everyExecutionState
.- Returns:
- timestamps for each state
-
getState
ExecutionState getState()
Returns the currentExecutionState
for this execution.- Returns:
- execution state for this execution
-
getAssignedResourceLocation
TaskManagerLocation getAssignedResourceLocation()
Returns theTaskManagerLocation
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
ofErrorInfo
containing theThrowable
and the time it was registered if an error occurred. If no error occurred an emptyOptional
will be returned.
-
getStateTimestamp
long getStateTimestamp(ExecutionState state)
Returns the timestamp for the givenExecutionState
.- Parameters:
state
- state for which the timestamp should be returned- Returns:
- timestamp for the given state
-
getStateEndTimestamp
long getStateEndTimestamp(ExecutionState state)
Returns the end timestamp for the givenExecutionState
.- 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()
-
-