Package | Description |
---|---|
org.apache.flink.client | |
org.apache.flink.client.program |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
RemoteExecutor.executePlanWithJars(JobWithJars program) |
Modifier and Type | Method and Description |
---|---|
JobWithJars |
PackagedProgram.getPlanWithJars()
Returns the plan with all required jars.
|
JobWithJars |
PackagedProgram.getPlanWithoutJars()
Returns the plan without the required jars when the files are already provided by the cluster.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.