Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.client.program | |
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)
Returns a dummy object for wrapping a JobSubmissionResult
|
Modifier and Type | Class and Description |
---|---|
static class |
DetachedEnvironment.DetachedJobExecutionResult |
Modifier and Type | Method and Description |
---|---|
JobSubmissionResult |
Client.runBlocking(PackagedProgram prog,
int parallelism) |
JobSubmissionResult |
Client.runDetached(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader) |
JobSubmissionResult |
Client.runDetached(FlinkPlan compiledPlan,
List<URL> libraries,
List<URL> classpaths,
ClassLoader classLoader,
String savepointPath) |
JobSubmissionResult |
Client.runDetached(JobGraph jobGraph,
ClassLoader classLoader) |
JobSubmissionResult |
Client.runDetached(JobWithJars program,
int parallelism) |
JobSubmissionResult |
Client.runDetached(JobWithJars program,
int parallelism,
String savepointPath)
Submits a program to the Flink cluster to which this client is connected.
|
JobSubmissionResult |
Client.runDetached(PackagedProgram prog,
int parallelism) |
Modifier and Type | Method and Description |
---|---|
JobSubmissionResult |
FlinkMiniCluster.submitJobDetached(JobGraph jobGraph) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.