Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.client.program | |
org.apache.flink.client.program.rest | |
org.apache.flink.runtime.minicluster |
Modifier and Type | Class and Description |
---|---|
class |
JobExecutionResult
The result of a job execution.
|
Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult result)
Deprecated.
Will be removed in future versions.
|
Modifier and Type | Class and Description |
---|---|
static class |
DetachedEnvironment.DetachedJobExecutionResult
The
JobExecutionResult returned by a DetachedEnvironment . |
Modifier and Type | Method and Description |
---|---|
JobSubmissionResult |
ClusterClient.run(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader) |
JobSubmissionResult |
ClusterClient.run(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader,
SavepointRestoreSettings savepointSettings) |
JobSubmissionResult |
ClusterClient.run(JobWithJars program,
int parallelism) |
JobSubmissionResult |
ClusterClient.run(JobWithJars jobWithJars,
int parallelism,
SavepointRestoreSettings savepointSettings)
Runs a program on the Flink cluster to which this client is connected.
|
JobSubmissionResult |
ClusterClient.run(PackagedProgram prog,
int parallelism)
General purpose method to run a user jar from the CliFrontend in either blocking or detached mode, depending
on whether
setDetached(true) or setDetached(false) . |
abstract JobSubmissionResult |
ClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader)
Calls the subclasses' submitJob method.
|
JobSubmissionResult |
MiniClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobSubmissionResult> |
NewClusterClient.submitJob(JobGraph jobGraph)
Submit the given
JobGraph to the cluster. |
CompletableFuture<JobSubmissionResult> |
MiniClusterClient.submitJob(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
JobSubmissionResult |
RestClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobSubmissionResult> |
RestClusterClient.submitJob(JobGraph jobGraph)
Submits the given
JobGraph to the dispatcher. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobSubmissionResult> |
MiniCluster.submitJob(JobGraph jobGraph) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.