@Internal public final class DetachedJobExecutionResult extends JobExecutionResult
JobExecutionResult
returned by a context environment when executing a job in detached
mode.Modifier and Type | Field and Description |
---|---|
static String |
DETACHED_MESSAGE |
static String |
EAGER_FUNCTION_MESSAGE |
static String |
JOB_RESULT_MESSAGE |
Constructor and Description |
---|
DetachedJobExecutionResult(JobID jobID) |
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() |
fromJobSubmissionResult, getNetRuntime
public static final String DETACHED_MESSAGE
public static final String EAGER_FUNCTION_MESSAGE
public static final String JOB_RESULT_MESSAGE
public DetachedJobExecutionResult(JobID jobID)
public long getNetRuntime()
JobExecutionResult
getNetRuntime
in class JobExecutionResult
public <T> T getAccumulatorResult(String accumulatorName)
JobExecutionResult
null
, if no accumulator with that
name was produced.getAccumulatorResult
in class JobExecutionResult
T
- The generic type of the accumulator value.accumulatorName
- The name of the accumulator.public Map<String,Object> getAllAccumulatorResults()
JobExecutionResult
getAllAccumulatorResults
in class JobExecutionResult
public Integer getIntCounterResult(String accumulatorName)
JobExecutionResult
getIntCounterResult
in class JobExecutionResult
accumulatorName
- Name of the counterpublic JobID getJobID()
JobSubmissionResult
getJobID
in class JobSubmissionResult
public boolean isJobExecutionResult()
JobSubmissionResult
getJobExecutionResult
to retrieve the JobExecutionResult.isJobExecutionResult
in class JobExecutionResult
public JobExecutionResult getJobExecutionResult()
JobSubmissionResult
getJobExecutionResult
in class JobExecutionResult
public String toString()
toString
in class JobExecutionResult
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.