Package org.apache.flink.optimizer.plan
Class BinaryUnionPlanNode
- java.lang.Object
-
- org.apache.flink.optimizer.plan.PlanNode
-
- org.apache.flink.optimizer.plan.DualInputPlanNode
-
- org.apache.flink.optimizer.plan.BinaryUnionPlanNode
-
- All Implemented Interfaces:
DumpableNode<PlanNode>,org.apache.flink.util.Visitable<PlanNode>
public class BinaryUnionPlanNode extends DualInputPlanNode
A special subclass for the union to make it identifiable.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.optimizer.plan.PlanNode
PlanNode.FeedbackPropertiesMeetRequirementsReport, PlanNode.SourceAndDamReport
-
-
Field Summary
-
Fields inherited from class org.apache.flink.optimizer.plan.DualInputPlanNode
input1, input2, keys1, keys2, postPassHelper1, postPassHelper2, sortOrders
-
Fields inherited from class org.apache.flink.optimizer.plan.PlanNode
branchPlan, cumulativeCosts, globalProps, localProps, nodeCosts, outChannels, template
-
-
Constructor Summary
Constructors Constructor Description BinaryUnionPlanNode(BinaryUnionNode template, Channel in1, Channel in2)BinaryUnionPlanNode(BinaryUnionPlanNode toSwapFrom)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetMemoryConsumerWeight()BinaryUnionNodegetOptimizerNode()booleanunionsStaticAndDynamicPath()-
Methods inherited from class org.apache.flink.optimizer.plan.DualInputPlanNode
accept, getComparator1, getComparator2, getInput1, getInput2, getInputs, getKeysForInput1, getKeysForInput2, getPairComparator, getPredecessors, getSortOrders, getTwoInputNode, hasDamOnPathDownTo, setComparator1, setComparator2, setPairComparator
-
Methods inherited from class org.apache.flink.optimizer.plan.PlanNode
addOutgoingChannel, checkPartialSolutionPropertiesMet, getBranchPlan, getBroadcastInputs, getCandidateAtBranchPoint, getCostWeight, getCumulativeCosts, getCumulativeCostsShare, getDriverStrategy, getDumpableInputs, getGlobalProperties, getGuaranteedAvailableMemory, getLocalProperties, getMinResources, getNodeCosts, getNodeName, getOriginalOptimizerNode, getOutgoingChannels, getParallelism, getPlanNode, getPreferredResources, getProgramOperator, getRelativeMemoryPerSubTask, initProperties, isOnDynamicPath, isPruneMarkerSet, mergeBranchPlanMaps, mergeBranchPlanMaps, setBroadcastInputs, setCosts, setDriverStrategy, setParallelism, setPruningMarker, setRelativeMemoryPerSubtask, toString, updatePropertiesWithUniqueSets
-
-
-
-
Constructor Detail
-
BinaryUnionPlanNode
public BinaryUnionPlanNode(BinaryUnionNode template, Channel in1, Channel in2)
- Parameters:
template-
-
BinaryUnionPlanNode
public BinaryUnionPlanNode(BinaryUnionPlanNode toSwapFrom)
-
-
Method Detail
-
getOptimizerNode
public BinaryUnionNode getOptimizerNode()
- Specified by:
getOptimizerNodein interfaceDumpableNode<PlanNode>- Overrides:
getOptimizerNodein classPlanNode
-
unionsStaticAndDynamicPath
public boolean unionsStaticAndDynamicPath()
-
getMemoryConsumerWeight
public int getMemoryConsumerWeight()
- Overrides:
getMemoryConsumerWeightin classPlanNode
-
-