org.apache.flink.api.common

Class JobSubmissionResult

java.lang.Object

org.apache.flink.api.common.JobSubmissionResult

Direct Known Subclasses:

JobExecutionResult

@Public
public class JobSubmissionResult
extends Object

The result of submitting a job to a JobManager.

Constructor Summary

Constructors

Constructor and Description
JobSubmissionResult(JobID jobID)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	getJobExecutionResult() Returns the JobExecutionResult if available.
JobID	getJobID() Returns the JobID assigned to the job by the Flink runtime.
boolean	isJobExecutionResult() Checks if this JobSubmissionResult is also a JobExecutionResult.

Methods inherited from class java.lang.Object

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

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