Package | Description |
---|---|
org.apache.flink.optimizer | |
org.apache.flink.optimizer.costs | |
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.dataproperties | |
org.apache.flink.optimizer.operators | |
org.apache.flink.optimizer.plan | |
org.apache.flink.optimizer.plandump | |
org.apache.flink.optimizer.plantranslate | |
org.apache.flink.optimizer.postpass | |
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.
|
org.apache.flink.optimizer.util |
Class and Description |
---|
OptimizedPlan
The execution plan generated by the Optimizer.
|
Class and Description |
---|
PlanNode
The representation of a data exchange between to operators.
|
Class and Description |
---|
BulkPartialSolutionPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
Channel
A Channel represents the result produced by an operator and the data exchange before the
consumption by the target operator.
|
NamedChannel |
PlanNode
The representation of a data exchange between to operators.
|
SingleInputPlanNode |
SolutionSetPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
WorksetPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
Class and Description |
---|
Channel
A Channel represents the result produced by an operator and the data exchange before the
consumption by the target operator.
|
Class and Description |
---|
Channel
A Channel represents the result produced by an operator and the data exchange before the
consumption by the target operator.
|
DualInputPlanNode |
SingleInputPlanNode |
Class and Description |
---|
BinaryUnionPlanNode
A special subclass for the union to make it identifiable.
|
BulkIterationPlanNode |
BulkPartialSolutionPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
Channel
A Channel represents the result produced by an operator and the data exchange before the
consumption by the target operator.
|
DualInputPlanNode |
IterationPlanNode |
NamedChannel |
PlanNode
The representation of a data exchange between to operators.
|
PlanNode.FeedbackPropertiesMeetRequirementsReport |
PlanNode.SourceAndDamReport |
SingleInputPlanNode |
SinkPlanNode
Plan candidate node for data flow sinks.
|
SolutionSetPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
SourcePlanNode
Plan candidate node for data flow sources that have no input and no special strategies.
|
WorksetIterationPlanNode
A node in the execution, representing a workset iteration (delta iteration).
|
WorksetPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
Class and Description |
---|
OptimizedPlan
The execution plan generated by the Optimizer.
|
PlanNode
The representation of a data exchange between to operators.
|
SinkPlanNode
Plan candidate node for data flow sinks.
|
Class and Description |
---|
OptimizedPlan
The execution plan generated by the Optimizer.
|
PlanNode
The representation of a data exchange between to operators.
|
Class and Description |
---|
OptimizedPlan
The execution plan generated by the Optimizer.
|
PlanNode
The representation of a data exchange between to operators.
|
Class and Description |
---|
Channel
A Channel represents the result produced by an operator and the data exchange before the
consumption by the target operator.
|
OptimizedPlan
The execution plan generated by the Optimizer.
|
PlanNode
The representation of a data exchange between to operators.
|
SinkPlanNode
Plan candidate node for data flow sinks.
|
Class and Description |
---|
Channel
A Channel represents the result produced by an operator and the data exchange before the
consumption by the target operator.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.