org.apache.flink.client.program

Class DetachedEnvironment.DetachedJobExecutionResult

java.lang.Object

org.apache.flink.api.common.JobSubmissionResult

org.apache.flink.api.common.JobExecutionResult

org.apache.flink.client.program.DetachedEnvironment.DetachedJobExecutionResult

Enclosing class:

DetachedEnvironment

public static final class DetachedEnvironment.DetachedJobExecutionResult
extends JobExecutionResult

Field Summary

Fields

Modifier and Type	Field and Description
static DetachedEnvironment.DetachedJobExecutionResult	INSTANCE

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.
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.

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, toString, wait, wait, wait

Field Detail

INSTANCE

public static final DetachedEnvironment.DetachedJobExecutionResult INSTANCE

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.