public class BulkPartialSolutionPlanNode extends PlanNode
PlanNode.FeedbackPropertiesMeetRequirementsReport, PlanNode.SourceAndDamReport
Modifier and Type | Field and Description |
---|---|
Object |
postPassHelper |
branchPlan, cumulativeCosts, globalProps, localProps, nodeCosts, outChannels, template
Constructor and Description |
---|
BulkPartialSolutionPlanNode(BulkPartialSolutionNode template,
String nodeName,
GlobalProperties gProps,
LocalProperties lProps,
Channel initialInput) |
Modifier and Type | Method and Description |
---|---|
void |
accept(Visitor<PlanNode> visitor)
Contains the logic to invoke the visitor and continue the traversal.
|
BulkIterationPlanNode |
getContainingIterationNode() |
Iterable<Channel> |
getInputs() |
BulkPartialSolutionNode |
getPartialSolutionNode() |
Iterable<PlanNode> |
getPredecessors()
Gets an iterator over the predecessors.
|
PlanNode.SourceAndDamReport |
hasDamOnPathDownTo(PlanNode source)
Checks whether this node has a dam on the way down to the given source node.
|
void |
setContainingIterationNode(BulkIterationPlanNode containingIterationNode) |
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, setCosts, setDriverStrategy, setParallelism, setPruningMarker, setRelativeMemoryPerSubtask, toString, updatePropertiesWithUniqueSets
public Object postPassHelper
public BulkPartialSolutionPlanNode(BulkPartialSolutionNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
public BulkPartialSolutionNode getPartialSolutionNode()
public BulkIterationPlanNode getContainingIterationNode()
public void setContainingIterationNode(BulkIterationPlanNode containingIterationNode)
public void accept(Visitor<PlanNode> visitor)
Visitable
A typical code example is the following:
public void accept(Visitor<Operator> visitor) {
boolean descend = visitor.preVisit(this);
if (descend) {
if (this.input != null) {
this.input.accept(visitor);
}
visitor.postVisit(this);
}
}
visitor
- The visitor to be called with this object as the parameter.Visitor.preVisit(Visitable)
,
Visitor.postVisit(Visitable)
public Iterable<PlanNode> getPredecessors()
DumpableNode
getPredecessors
in interface DumpableNode<PlanNode>
getPredecessors
in class PlanNode
public PlanNode.SourceAndDamReport hasDamOnPathDownTo(PlanNode source)
PlanNode
hasDamOnPathDownTo
in class PlanNode
source
- The node on the path to which the dam is sought.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.