Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.client.program | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.yarn |
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 |
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) . |
JobSubmissionResult |
ClusterClient.runDetached(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph detached.
|
protected JobSubmissionResult |
StandaloneClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
protected abstract JobSubmissionResult |
ClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader)
Calls the subclasses' submitJob method.
|
Modifier and Type | Method and Description |
---|---|
JobSubmissionResult |
FlinkMiniCluster.submitJobDetached(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
protected JobSubmissionResult |
YarnClusterClientV2.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
protected JobSubmissionResult |
YarnClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.