Package | Description |
---|---|
org.apache.flink.api.common | |
org.apache.flink.api.common.operators | |
org.apache.flink.api.java | |
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala | |
org.apache.flink.client | |
org.apache.flink.client.program | |
org.apache.flink.optimizer | |
org.apache.flink.optimizer.plan | |
org.apache.flink.optimizer.traversals |
This package contains the various traversals over the program plan and the
optimizer DAG (directed acyclic graph) that are made in the course of
the optimization.
|
Modifier and Type | Method and Description |
---|---|
Plan |
Program.getPlan(String... args)
The method which is invoked by the compiler to get the job that is then compiled into an
executable schedule.
|
Modifier and Type | Method and Description |
---|---|
abstract JobExecutionResult |
PlanExecutor.executePlan(Plan plan)
Execute the given program.
|
abstract String |
PlanExecutor.getOptimizerPlanAsJSON(Plan plan)
Gets the programs execution plan in a JSON format.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
CollectionExecutor.execute(Plan program) |
Modifier and Type | Method and Description |
---|---|
Plan |
ExecutionEnvironment.createProgramPlan()
Creates the program's
Plan . |
Plan |
ExecutionEnvironment.createProgramPlan(String jobName)
Creates the program's
Plan . |
Plan |
ExecutionEnvironment.createProgramPlan(String jobName,
boolean clearSinks)
Creates the program's
Plan . |
Modifier and Type | Method and Description |
---|---|
protected void |
ExecutionEnvironment.registerCachedFilesWithPlan(Plan p)
Registers all files that were registered at this execution environment's cache registry of the
given plan's cache registry.
|
Modifier and Type | Method and Description |
---|---|
Plan |
OperatorTranslation.translateToPlan(List<DataSink<?>> sinks,
String jobName) |
Modifier and Type | Method and Description |
---|---|
Plan |
ExecutionEnvironment.createProgramPlan(String jobName)
Creates the program's
Plan . |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResult |
LocalExecutor.execute(Plan plan)
Executes the given dataflow plan.
|
JobExecutionResult |
RemoteExecutor.executePlan(Plan plan) |
JobExecutionResult |
LocalExecutor.executePlan(Plan plan)
Executes the given program on a local runtime and waits for the job to finish.
|
String |
RemoteExecutor.getOptimizerPlanAsJSON(Plan plan) |
String |
LocalExecutor.getOptimizerPlanAsJSON(Plan plan)
Creates a JSON representation of the given dataflow's execution plan.
|
static String |
LocalExecutor.getPlanAsJSON(Plan plan)
Creates a JSON representation of the given dataflow plan.
|
static String |
LocalExecutor.optimizerPlanAsJSON(Plan plan)
Creates a JSON representation of the given dataflow's execution plan.
|
Modifier and Type | Method and Description |
---|---|
Plan |
PreviewPlanEnvironment.getPlan() |
Plan |
JobWithJars.getPlan()
Returns the plan
|
Modifier and Type | Method and Description |
---|---|
static OptimizedPlan |
ClusterClient.getOptimizedPlan(Optimizer compiler,
Plan p,
int parallelism) |
Constructor and Description |
---|
JobWithJars(Plan plan,
List<URL> jarFiles,
List<URL> classpaths) |
JobWithJars(Plan plan,
URL jarFile) |
Modifier and Type | Method and Description |
---|---|
OptimizedPlan |
Optimizer.compile(Plan program)
Translates the given program to an OptimizedPlan, where all nodes have their local strategy assigned
and all channels have a shipping strategy assigned.
|
static List<DataSinkNode> |
Optimizer.createPreOptimizedPlan(Plan program)
This function performs only the first step to the compilation process - the creation of the optimizer
representation of the plan.
|
Modifier and Type | Method and Description |
---|---|
Plan |
OptimizedPlan.getOriginalPlan()
Gets the original program's dataflow plan from which this optimized plan was created.
|
Constructor and Description |
---|
OptimizedPlan(Collection<SourcePlanNode> sources,
Collection<SinkPlanNode> sinks,
Collection<PlanNode> allNodes,
String jobName,
Plan programPlan)
Creates a new instance of this optimizer plan container.
|
Modifier and Type | Method and Description |
---|---|
OptimizedPlan |
PlanFinalizer.createFinalPlan(List<SinkPlanNode> sinks,
String jobName,
Plan originalPlan) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.