Interface | Description |
---|---|
EstimateProvider |
Methods for operators / connections that provide estimated about data size and characteristics.
|
IterationNode |
Class | Description |
---|---|
AbstractPartialSolutionNode |
The optimizer's internal representation of the partial solution that is input to a bulk
iteration.
|
BinaryUnionNode |
The Optimizer representation of a binary Union.
|
BinaryUnionNode.UnionSemanticProperties | |
BulkIterationNode |
A node in the optimizer's program representation for a bulk iteration.
|
BulkPartialSolutionNode |
The optimizer's internal representation of the partial solution that is input to a bulk
iteration.
|
CoGroupNode |
The Optimizer representation of a CoGroup operator.
|
CoGroupRawNode |
The Optimizer representation of a CoGroupRaw operator.
|
CrossNode |
The Optimizer representation of a Cross (Cartesian product) operator.
|
DagConnection |
A connection between two operators.
|
DataSinkNode |
The Optimizer representation of a data sink.
|
DataSourceNode |
The optimizer's internal representation of a data source.
|
FilterNode |
The optimizer's internal representation of a Filter operator node.
|
FlatMapNode |
The optimizer's internal representation of a FlatMap operator node.
|
GroupCombineNode |
The optimizer representation of a GroupCombineNode operation.
|
GroupReduceNode |
The optimizer representation of a GroupReduce operation.
|
JoinNode |
The Optimizer representation of a join operator.
|
MapNode |
The optimizer's internal representation of a Map operator node.
|
MapPartitionNode |
The optimizer's internal representation of a MapPartition operator node.
|
NoOpNode |
The optimizer's internal representation of a No Operation node.
|
OptimizerNode |
The OptimizerNode is the base class of all nodes in the optimizer DAG.
|
OptimizerNode.UnclosedBranchDescriptor |
Description of an unclosed branch.
|
OuterJoinNode | |
PartitionNode |
The optimizer's internal representation of a Partition operator node.
|
PartitionNode.PartitionDescriptor | |
ReduceNode |
The Optimizer representation of a Reduce operator.
|
SingleInputNode |
A node in the optimizer's program representation for an operation with a single input.
|
SinkJoiner |
This class represents a utility node that is not part of the actual plan.
|
SolutionSetNode |
The optimizer's internal representation of the solution set of a workset iteration.
|
SortPartitionNode |
The optimizer's internal representation of a SortPartition operator node.
|
SortPartitionNode.SortPartitionDescriptor | |
TwoInputNode |
A node in the optimizer plan that represents an operator with a two different inputs, such as
Join, Cross, CoGroup, or Union.
|
UnaryOperatorNode | |
WorksetIterationNode |
A node in the optimizer's program representation for a workset iteration.
|
WorksetIterationNode.SingleRootJoiner | |
WorksetNode |
The optimizer's internal representation of the partial solution that is input to a bulk
iteration.
|
Enum | Description |
---|---|
TempMode |
Enumeration to indicate the mode of temporarily materializing the data that flows across a
connection.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.