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>, 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 and Description
BinaryUnionPlanNode(BinaryUnionNode template, Channel in1, Channel in2)
BinaryUnionPlanNode(BinaryUnionPlanNode toSwapFrom)

Method Summary

Modifier and Type	Method and Description
int	getMemoryConsumerWeight()
BinaryUnionNode	getOptimizerNode()
boolean	unionsStaticAndDynamicPath()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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:

getOptimizerNode in interface DumpableNode<PlanNode>

Overrides:

getOptimizerNode in class PlanNode

unionsStaticAndDynamicPath

public boolean unionsStaticAndDynamicPath()

getMemoryConsumerWeight

public int getMemoryConsumerWeight()

Overrides:

getMemoryConsumerWeight in class PlanNode