Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult result)
Deprecated.
Will be removed in future versions.
|
JobExecutionResult |
JobSubmissionResult.getJobExecutionResult()
Returns the JobExecutionResult if available.
|
JobExecutionResult |
JobExecutionResult.getJobExecutionResult() |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
CollectionExecutor.execute(Plan program) |
Modifier and Type | Field and Description |
---|---|
protected JobExecutionResult |
ExecutionEnvironment.lastJobExecutionResult
Result from the latest execution, to make it retrievable when using eager execution methods.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
ExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
JobExecutionResult |
CollectionEnvironment.execute(String jobName) |
JobExecutionResult |
ExecutionEnvironment.getLastJobExecutionResult()
Returns the
JobExecutionResult of the last executed job. |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
ClientUtils.submitJob(ClusterClient<?> client,
JobGraph jobGraph) |
static JobExecutionResult |
ClientUtils.submitJobAndWaitForResult(ClusterClient<?> client,
JobGraph jobGraph,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobExecutionResult> |
ClusterClientJobClientAdapter.getJobExecutionResult(ClassLoader userClassloader) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobExecutionResult> |
WebSubmissionJobClient.getJobExecutionResult(ClassLoader userClassloader) |
CompletableFuture<JobExecutionResult> |
EmbeddedJobClient.getJobExecutionResult(ClassLoader userClassloader) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamContextEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
ContextEnvironment.execute(String jobName) |
Modifier and Type | Class and Description |
---|---|
class |
DetachedJobExecutionResult
The
JobExecutionResult returned by a context environment when executing a job in detached
mode. |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DetachedJobExecutionResult.getJobExecutionResult() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobExecutionResult> |
JobClient.getJobExecutionResult(ClassLoader userClassloader)
Returns the
result of the job execution of the submitted job. |
Modifier and Type | Method and Description |
---|---|
void |
JobListener.onJobExecuted(JobExecutionResult jobExecutionResult,
Throwable throwable)
Callback on job execution finished, successfully or unsuccessfully.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
SerializedJobExecutionResult.toJobExecutionResult(ClassLoader loader) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
JobResult.toJobExecutionResult(ClassLoader classLoader)
Converts the
JobResult to a JobExecutionResult . |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
JobExecutor.executeJobBlocking(JobGraph jobGraph)
Run the given job and block until its execution result can be returned.
|
JobExecutionResult |
MiniCluster.executeJobBlocking(JobGraph job)
This method runs a job in blocking mode.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutionEnvironment.execute()
Triggers the program execution.
|
JobExecutionResult |
StreamExecutionEnvironment.execute(StreamGraph streamGraph)
Triggers the program execution.
|
JobExecutionResult |
LocalStreamEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
RemoteStreamEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
StreamExecutionEnvironment.execute(String jobName)
Triggers the program execution.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TestStreamEnvironment.execute(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TableEnvironment.execute(String jobName)
Deprecated.
use
TableEnvironment.executeSql(String) or Table.executeInsert(String) for single
sink, use TableEnvironment.createStatementSet() for multiple sinks. |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamTableEnvironment.execute(String jobName)
Triggers the program execution.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TableEnvironmentImpl.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
Executor.execute(Pipeline pipeline)
Executes the given pipeline.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutor.execute(Pipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ExecutorBase.execute(Pipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DummyStreamExecutionEnvironment.execute() |
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DummyStreamExecutionEnvironment.execute() |
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TestEnvironment.execute(String jobName) |
JobExecutionResult |
CollectionTestEnvironment.execute(String jobName) |
JobExecutionResult |
TestEnvironment.getLastJobExecutionResult() |
JobExecutionResult |
CollectionTestEnvironment.getLastJobExecutionResult() |
JobExecutionResult |
JavaProgramTestBase.getLatestExecutionResult() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.