Package | Description |
---|---|
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.plan | |
org.apache.flink.optimizer.plandump |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPartialSolutionNode
The optimizer's internal representation of the partial solution that is input to a bulk
iteration.
|
class |
BinaryUnionNode
The Optimizer representation of a binary Union.
|
class |
BulkIterationNode
A node in the optimizer's program representation for a bulk iteration.
|
class |
BulkPartialSolutionNode
The optimizer's internal representation of the partial solution that is input to a bulk
iteration.
|
class |
CoGroupNode
The Optimizer representation of a CoGroup operator.
|
class |
CoGroupRawNode
The Optimizer representation of a CoGroupRaw operator.
|
class |
CrossNode
The Optimizer representation of a Cross (Cartesian product) operator.
|
class |
DataSinkNode
The Optimizer representation of a data sink.
|
class |
DataSourceNode
The optimizer's internal representation of a data source.
|
class |
FilterNode
The optimizer's internal representation of a Filter operator node.
|
class |
FlatMapNode
The optimizer's internal representation of a FlatMap operator node.
|
class |
GroupCombineNode
The optimizer representation of a GroupCombineNode operation.
|
class |
GroupReduceNode
The optimizer representation of a GroupReduce operation.
|
class |
JoinNode
The Optimizer representation of a join operator.
|
class |
MapNode
The optimizer's internal representation of a Map operator node.
|
class |
MapPartitionNode
The optimizer's internal representation of a MapPartition operator node.
|
class |
NoOpNode
The optimizer's internal representation of a No Operation node.
|
class |
OptimizerNode
The OptimizerNode is the base class of all nodes in the optimizer DAG.
|
class |
OuterJoinNode |
class |
PartitionNode
The optimizer's internal representation of a Partition operator node.
|
class |
ReduceNode
The Optimizer representation of a Reduce operator.
|
class |
SingleInputNode
A node in the optimizer's program representation for an operation with a single input.
|
class |
SinkJoiner
This class represents a utility node that is not part of the actual plan.
|
class |
SolutionSetNode
The optimizer's internal representation of the solution set of a workset iteration.
|
class |
SortPartitionNode
The optimizer's internal representation of a SortPartition operator node.
|
class |
TwoInputNode
A node in the optimizer plan that represents an operator with a two different inputs, such as
Join, Cross, CoGroup, or Union.
|
class |
UnaryOperatorNode |
class |
WorksetIterationNode
A node in the optimizer's program representation for a workset iteration.
|
static class |
WorksetIterationNode.SingleRootJoiner |
class |
WorksetNode
The optimizer's internal representation of the partial solution that is input to a bulk
iteration.
|
Modifier and Type | Class and Description |
---|---|
class |
BinaryUnionPlanNode
A special subclass for the union to make it identifiable.
|
class |
BulkIterationPlanNode |
class |
BulkPartialSolutionPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
class |
DualInputPlanNode |
class |
NAryUnionPlanNode
A union operation over multiple inputs (2 or more).
|
class |
PlanNode
The representation of a data exchange between two operators.
|
class |
SingleInputPlanNode |
class |
SinkJoinerPlanNode |
class |
SinkPlanNode
Plan candidate node for data flow sinks.
|
class |
SolutionSetPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
class |
SourcePlanNode
Plan candidate node for data flow sources that have no input and no special strategies.
|
class |
WorksetIterationPlanNode
A node in the execution, representing a workset iteration (delta iteration).
|
class |
WorksetPlanNode
Plan candidate node for partial solution of a bulk iteration.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DumpableConnection<T extends DumpableNode<T>> |
interface |
DumpableNode<T extends DumpableNode<T>> |
Modifier and Type | Method and Description |
---|---|
DumpableNode<T> |
DumpableConnection.getSource() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.