Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.api.java | |
org.apache.flink.api.java.operators | |
org.apache.flink.optimizer | |
org.apache.flink.optimizer.plan | |
org.apache.flink.optimizer.plandump | |
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 |
---|---|
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 |
---|---|
String |
ExecutionPlanUtil.ExecutionPlanJSONGenerator.getExecutionPlan(Plan plan)
Returns the execution plan as a JSON string.
|
static String |
ExecutionPlanUtil.getExecutionPlanAsJSON(Plan plan)
Extracts the execution plan (as JSON) from the given
Plan . |
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 |
---|---|
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 |
---|---|
String |
ExecutionPlanJSONGenerator.getExecutionPlan(Plan plan) |
Modifier and Type | Method and Description |
---|---|
OptimizedPlan |
PlanFinalizer.createFinalPlan(List<SinkPlanNode> sinks,
String jobName,
Plan originalPlan) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.