SingleInputPlanNode |
MapPartitionDescriptor.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
PartialGroupProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
GroupCombineProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
GroupReduceProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
AllGroupWithPartialPreGroupProperties.instantiate(Channel in,
SingleInputNode node) |
abstract SingleInputPlanNode |
OperatorDescriptorSingle.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
AllGroupCombineProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
AllGroupReduceProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
AllReduceProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
FilterDescriptor.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
MapDescriptor.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
FlatMapDescriptor.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
NoOpDescriptor.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
ReduceProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
GroupReduceWithCombineProperties.instantiate(Channel in,
SingleInputNode node) |
SingleInputPlanNode |
SolutionSetDeltaOperator.instantiate(Channel in,
SingleInputNode node) |