Interface AccessExecution

    • Method Detail

      • getAttemptNumber

        int getAttemptNumber()
        Returns the attempt number for this execution.
        Returns:
        attempt number for this execution.
      • getStateTimestamps

        long[] getStateTimestamps()
        Returns the timestamps for every ExecutionState.
        Returns:
        timestamps for each state
      • getStateEndTimestamps

        long[] getStateEndTimestamps()
        Returns the end timestamps for every ExecutionState.
        Returns:
        timestamps for each 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:
        an Optional of ErrorInfo containing the Throwable and the time it was registered if an error occurred. If no error occurred an empty Optional will be returned.
      • 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
      • getStateEndTimestamp

        long getStateEndTimestamp​(ExecutionState state)
        Returns the end timestamp for the given ExecutionState.
        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.