Package | Description |
---|---|
org.apache.flink.client | |
org.apache.flink.client.cli | |
org.apache.flink.client.program |
Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.executeProgram(PipelineExecutorServiceLoader executorServiceLoader,
Configuration configuration,
PackagedProgram program) |
Modifier and Type | Method and Description |
---|---|
protected void |
CliFrontend.executeProgram(Configuration configuration,
PackagedProgram program) |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
PackagedProgram.Builder.build() |
Modifier and Type | Method and Description |
---|---|
static JobGraph |
PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
boolean suppressOutput)
|
static JobGraph |
PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram,
Configuration configuration,
int defaultParallelism,
JobID jobID,
boolean suppressOutput)
|
Pipeline |
OptimizerPlanEnvironment.getPipeline(PackagedProgram prog,
boolean suppressOutput)
Retrieves the JobGraph from a PackagedProgram.
|
static Pipeline |
PackagedProgramUtils.getPipelineFromProgram(PackagedProgram prog,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.