Modifier and Type | Method and Description |
---|---|
JobClient |
ExecutionEnvironment.executeAsync()
Triggers the program execution asynchronously.
|
JobClient |
ScalaShellStreamEnvironment.executeAsync(StreamGraph streamGraph) |
JobClient |
ScalaShellEnvironment.executeAsync(String jobName) |
JobClient |
ExecutionEnvironment.executeAsync(String jobName)
Triggers the program execution asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
ClusterClientJobClientAdapter<ClusterID>
An implementation of the
JobClient interface that uses a ClusterClient underneath.. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
AbstractJobClusterExecutor.execute(Pipeline pipeline,
Configuration configuration) |
CompletableFuture<? extends JobClient> |
LocalExecutor.execute(Pipeline pipeline,
Configuration configuration) |
CompletableFuture<JobClient> |
AbstractSessionClusterExecutor.execute(Pipeline pipeline,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
JobClient |
OptimizerPlanEnvironment.executeAsync(String jobName) |
JobClient |
ContextEnvironment.executeAsync(String jobName) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<? extends JobClient> |
PerJobMiniClusterFactory.submitJob(JobGraph jobGraph)
Starts a
MiniCluster and submits a job. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<? extends JobClient> |
PipelineExecutor.execute(Pipeline pipeline,
Configuration configuration)
|
Modifier and Type | Method and Description |
---|---|
void |
JobListener.onJobSubmitted(JobClient jobClient,
Throwable throwable)
Callback on job submission.
|
Modifier and Type | Method and Description |
---|---|
JobClient |
StreamExecutionEnvironment.executeAsync()
Triggers the program asynchronously.
|
JobClient |
StreamExecutionEnvironment.executeAsync(StreamGraph streamGraph)
Triggers the program execution asynchronously.
|
JobClient |
StreamPlanEnvironment.executeAsync(StreamGraph streamGraph) |
JobClient |
StreamContextEnvironment.executeAsync(StreamGraph streamGraph) |
JobClient |
StreamExecutionEnvironment.executeAsync(String jobName)
Triggers the program execution asynchronously.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<? extends JobClient> |
ProgramDeployer.deploy() |
Modifier and Type | Method and Description |
---|---|
void |
CollectStreamResult.startRetrieval(JobClient jobClient) |
void |
DynamicResult.startRetrieval(JobClient jobClient)
Starts retrieving the result using the given
JobClient and monitors it's execution. |
void |
MaterializedCollectBatchResult.startRetrieval(JobClient jobClient) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.