Package org.apache.flink.core.execution

Class DetachedJobExecutionResult

  • @Internal
public final class DetachedJobExecutionResult
extends JobExecutionResult
    The JobExecutionResult returned by a context environment when executing a job in detached mode.

    • Constructor Detail

      • DetachedJobExecutionResult

        public DetachedJobExecutionResult​(JobID jobID)

    • Method Detail

      • getNetRuntime

        public long getNetRuntime()
        Description copied from class: JobExecutionResult
        Gets the net execution time of the job, i.e., the execution time in the parallel system, without the pre-flight steps like the optimizer.
        Overrides:
        getNetRuntime in class JobExecutionResult
        Returns:
        The net execution time in milliseconds.

      • getAccumulatorResult

        public <T> T getAccumulatorResult​(String accumulatorName)
        Description copied from class: JobExecutionResult
        Gets the accumulator with the given name. Returns null, if no accumulator with that name was produced.
        Overrides:
        getAccumulatorResult in class JobExecutionResult
        Type Parameters:
        T - The generic type of the accumulator value.
        Parameters:
        accumulatorName - The name of the accumulator.
        Returns:
        The value of the accumulator with the given name.

      • getAllAccumulatorResults

        public Map<String,​Object> getAllAccumulatorResults()
        Description copied from class: JobExecutionResult
        Gets all accumulators produced by the job. The map contains the accumulators as mappings from the accumulator name to the accumulator value.
        Overrides:
        getAllAccumulatorResults in class JobExecutionResult
        Returns:
        A map containing all accumulators produced by the job.

      • getIntCounterResult

        public Integer getIntCounterResult​(String accumulatorName)
        Description copied from class: JobExecutionResult
        Gets the accumulator with the given name as an integer.
        Overrides:
        getIntCounterResult in class JobExecutionResult
        Parameters:
        accumulatorName - Name of the counter
        Returns:
        Result of the counter, or null if the counter does not exist

      • getJobID

        public JobID getJobID()
        Description copied from class: JobSubmissionResult
        Returns the JobID assigned to the job by the Flink runtime.
        Overrides:
        getJobID in class JobSubmissionResult
        Returns:
        jobID, or null if the job has been executed on a runtime without JobIDs or if the execution failed.

      • isJobExecutionResult

        public boolean isJobExecutionResult()
        Description copied from class: JobSubmissionResult
        Checks if this JobSubmissionResult is also a JobExecutionResult. See getJobExecutionResult to retrieve the JobExecutionResult.
        Overrides:
        isJobExecutionResult in class JobExecutionResult
        Returns:
        True if this is a JobExecutionResult, false otherwise