org.apache.flink.core.execution

Class DetachedJobExecutionResult

java.lang.Object

org.apache.flink.api.common.JobSubmissionResult

org.apache.flink.api.common.JobExecutionResult

org.apache.flink.core.execution.DetachedJobExecutionResult

@Internal
public final class DetachedJobExecutionResult
extends JobExecutionResult

The JobExecutionResult returned by a context environment when executing a job in detached mode.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DETACHED_MESSAGE
static String	EAGER_FUNCTION_MESSAGE
static String	JOB_RESULT_MESSAGE

Constructor Summary

Constructors

Constructor and Description
DetachedJobExecutionResult(JobID jobID)

Method Summary

Modifier and Type	Method and Description
<T> T	getAccumulatorResult(String accumulatorName) Gets the accumulator with the given name.
Map<String,Object>	getAllAccumulatorResults() Gets all accumulators produced by the job.
Integer	getIntCounterResult(String accumulatorName) Gets the accumulator with the given name as an integer.
JobExecutionResult	getJobExecutionResult() Returns the JobExecutionResult if available.
JobID	getJobID() Returns the JobID assigned to the job by the Flink runtime.
long	getNetRuntime() 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.
boolean	isJobExecutionResult() Checks if this JobSubmissionResult is also a JobExecutionResult.
String	toString()

Methods inherited from class org.apache.flink.api.common.JobExecutionResult

fromJobSubmissionResult, getNetRuntime

Methods inherited from class java.lang.Object

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

Field Detail

DETACHED_MESSAGE

public static final String DETACHED_MESSAGE

See Also:

Constant Field Values

EAGER_FUNCTION_MESSAGE

public static final String EAGER_FUNCTION_MESSAGE

See Also:

Constant Field Values

JOB_RESULT_MESSAGE

public static final String JOB_RESULT_MESSAGE

See Also:

Constant Field Values

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

getJobExecutionResult

public JobExecutionResult getJobExecutionResult()

Description copied from class: JobSubmissionResult

Returns the JobExecutionResult if available.

Overrides:

getJobExecutionResult in class JobExecutionResult

Returns:

The JobExecutionResult

toString

public String toString()

Overrides:

toString in class JobExecutionResult