public class SinkJoinerPlanNode extends DualInputPlanNode
PlanNode.FeedbackPropertiesMeetRequirementsReport, PlanNode.SourceAndDamReport
input1, input2, keys1, keys2, postPassHelper1, postPassHelper2, sortOrders
branchPlan, cumulativeCosts, globalProps, localProps, nodeCosts, outChannels, template
Constructor and Description |
---|
SinkJoinerPlanNode(SinkJoiner template,
Channel input1,
Channel input2) |
Modifier and Type | Method and Description |
---|---|
void |
getDataSinks(List<SinkPlanNode> sinks) |
void |
setCosts(Costs nodeCosts)
Sets the basic cost for this node to the given value, and sets the cumulative costs to those
costs plus the cost shares of all inputs (regular and broadcast).
|
accept, getComparator1, getComparator2, getInput1, getInput2, getInputs, getKeysForInput1, getKeysForInput2, getPairComparator, getPredecessors, getSortOrders, getTwoInputNode, hasDamOnPathDownTo, setComparator1, setComparator2, setPairComparator
addOutgoingChannel, checkPartialSolutionPropertiesMet, getBranchPlan, getBroadcastInputs, getCandidateAtBranchPoint, getCostWeight, getCumulativeCosts, getCumulativeCostsShare, getDriverStrategy, getDumpableInputs, getGlobalProperties, getGuaranteedAvailableMemory, getLocalProperties, getMemoryConsumerWeight, getMinResources, getNodeCosts, getNodeName, getOptimizerNode, getOriginalOptimizerNode, getOutgoingChannels, getParallelism, getPlanNode, getPreferredResources, getProgramOperator, getRelativeMemoryPerSubTask, initProperties, isOnDynamicPath, isPruneMarkerSet, mergeBranchPlanMaps, mergeBranchPlanMaps, setBroadcastInputs, setDriverStrategy, setParallelism, setPruningMarker, setRelativeMemoryPerSubtask, toString, updatePropertiesWithUniqueSets
public SinkJoinerPlanNode(SinkJoiner template, Channel input1, Channel input2)
public void setCosts(Costs nodeCosts)
PlanNode
public void getDataSinks(List<SinkPlanNode> sinks)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.