Package | Description |
---|---|
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.operators | |
org.apache.flink.optimizer.plan |
Modifier and Type | Class and Description |
---|---|
class |
BulkIterationNode
A node in the optimizer's program representation for a bulk iteration.
|
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 |
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 |
PartitionNode
The optimizer's internal representation of a Partition operator node.
|
class |
ReduceNode
The Optimizer representation of a Reduce operator.
|
class |
SortPartitionNode
The optimizer's internal representation of a SortPartition operator node.
|
class |
UnaryOperatorNode |
Modifier and Type | Method and Description |
---|---|
SingleInputPlanNode |
PartitionNode.PartitionDescriptor.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
SortPartitionNode.SortPartitionDescriptor.instantiate(Channel in,
SingleInputNode node) |
Constructor and Description |
---|
SingleInputNode(SingleInputNode toCopy) |
Modifier and Type | Method and Description |
---|---|
SingleInputNode |
SingleInputPlanNode.getSingleInputNode() |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.