Package | Description |
---|---|
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.operators | |
org.apache.flink.optimizer.plan |
Modifier and Type | Class and Description |
---|---|
class |
BinaryUnionNode
The Optimizer representation of a binary Union.
|
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 |
JoinNode
The Optimizer representation of a join operator.
|
class |
OuterJoinNode |
class |
SinkJoiner
This class represents a utility node that is not part of the actual plan.
|
class |
WorksetIterationNode
A node in the optimizer's program representation for a workset iteration.
|
static class |
WorksetIterationNode.SingleRootJoiner |
Modifier and Type | Method and Description |
---|---|
TwoInputNode |
WorksetIterationNode.getSingleRootOfStepFunction() |
Modifier and Type | Method and Description |
---|---|
DualInputPlanNode |
CartesianProductDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashRightOuterJoinBuildSecondDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashRightOuterJoinBuildFirstDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
AbstractSortMergeJoinDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
CoGroupDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashJoinBuildFirstProperties.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
UtilSinkJoinOpDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashFullOuterJoinBuildFirstDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashJoinBuildSecondProperties.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashLeftOuterJoinBuildSecondDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashLeftOuterJoinBuildFirstDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
BinaryUnionOpDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
CoGroupRawDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
CoGroupWithSolutionSetFirstDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
abstract DualInputPlanNode |
OperatorDescriptorDual.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
DualInputPlanNode |
HashFullOuterJoinBuildSecondDescriptor.instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
Modifier and Type | Method and Description |
---|---|
TwoInputNode |
DualInputPlanNode.getTwoInputNode() |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.