Class JobSubmissionResult

  • Direct Known Subclasses:
    JobExecutionResult

    @Public
    public class JobSubmissionResult
    extends Object
    The result of submitting a job to a JobManager.
    • Constructor Detail

      • JobSubmissionResult

        public JobSubmissionResult​(JobID jobID)
    • Method Detail

      • getJobID

        public JobID getJobID()
        Returns the JobID assigned to the job by the Flink runtime.
        Returns:
        jobID, or null if the job has been executed on a runtime without JobIDs or if the execution failed.
      • isJobExecutionResult

        public boolean isJobExecutionResult()
        Checks if this JobSubmissionResult is also a JobExecutionResult. See getJobExecutionResult to retrieve the JobExecutionResult.
        Returns:
        True if this is a JobExecutionResult, false otherwise
      • getJobExecutionResult

        public JobExecutionResult getJobExecutionResult()
        Returns the JobExecutionResult if available.
        Returns:
        The JobExecutionResult
        Throws:
        ClassCastException - if this is not a JobExecutionResult