Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.optimizer.plan | |
org.apache.flink.streaming.api.graph |
Modifier and Type | Method and Description |
---|---|
static FlinkPlan |
ClusterClient.getOptimizedPlan(Optimizer compiler,
PackagedProgram prog,
int parallelism) |
FlinkPlan |
OptimizerPlanEnvironment.getOptimizedPlan(PackagedProgram prog) |
Modifier and Type | Method and Description |
---|---|
static JobGraph |
ClusterClient.getJobGraph(Configuration flinkConfig,
FlinkPlan optPlan,
List<URL> jarFiles,
List<URL> classpaths,
SavepointRestoreSettings savepointSettings) |
static JobGraph |
ClusterClient.getJobGraph(Configuration flinkConfig,
PackagedProgram prog,
FlinkPlan optPlan,
SavepointRestoreSettings savepointSettings) |
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) |
void |
DetachedEnvironment.setDetachedPlan(FlinkPlan plan) |
void |
OptimizerPlanEnvironment.setPlan(FlinkPlan plan) |
Modifier and Type | Class and Description |
---|---|
class |
OptimizedPlan
The execution plan generated by the Optimizer.
|
class |
StreamingPlan
Abstract class representing Flink Streaming plans
|
Modifier and Type | Class and Description |
---|---|
class |
StreamGraph
Class representing the streaming topology.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.