public class BulkIterationPlanNode extends SingleInputPlanNode implements IterationPlanNode
PlanNode.FeedbackPropertiesMeetRequirementsReport, PlanNode.SourceAndDamReport
driverKeys, driverSortOrders, input, postPassHelper
branchPlan, cumulativeCosts, globalProps, localProps, nodeCosts, outChannels, template
Constructor and Description |
---|
BulkIterationPlanNode(BulkIterationNode template,
String nodeName,
Channel input,
BulkPartialSolutionPlanNode pspn,
PlanNode rootOfStepFunction) |
BulkIterationPlanNode(BulkIterationNode template,
String nodeName,
Channel input,
BulkPartialSolutionPlanNode pspn,
PlanNode rootOfStepFunction,
PlanNode rootOfTerminationCriterion) |
Modifier and Type | Method and Description |
---|---|
void |
acceptForStepFunction(Visitor<PlanNode> visitor) |
BulkIterationNode |
getIterationNode() |
int |
getMemoryConsumerWeight() |
BulkPartialSolutionPlanNode |
getPartialSolutionPlanNode() |
PlanNode |
getRootOfStepFunction() |
PlanNode |
getRootOfTerminationCriterion() |
TypeSerializerFactory<?> |
getSerializerForIterationChannel() |
PlanNode.SourceAndDamReport |
hasDamOnPathDownTo(PlanNode source)
Checks whether this node has a dam on the way down to the given source node.
|
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).
|
void |
setSerializerForIterationChannel(TypeSerializerFactory<?> serializerForIterationChannel) |
accept, getComparator, getInput, getInputs, getKeys, getPredecessor, getPredecessors, getSingleInputNode, getSortOrders, getTrueArray, setComparator, setDriverKeyInfo, setDriverKeyInfo
addOutgoingChannel, checkPartialSolutionPropertiesMet, getBranchPlan, getBroadcastInputs, getCandidateAtBranchPoint, getCostWeight, getCumulativeCosts, getCumulativeCostsShare, getDriverStrategy, getDumpableInputs, getGlobalProperties, getGuaranteedAvailableMemory, getLocalProperties, getMinResources, getNodeCosts, getNodeName, getOptimizerNode, getOriginalOptimizerNode, getOutgoingChannels, getParallelism, getPlanNode, getPreferredResources, getProgramOperator, getRelativeMemoryPerSubTask, initProperties, isOnDynamicPath, isPruneMarkerSet, mergeBranchPlanMaps, mergeBranchPlanMaps, setBroadcastInputs, setDriverStrategy, setParallelism, setPruningMarker, setRelativeMemoryPerSubtask, toString, updatePropertiesWithUniqueSets
public BulkIterationPlanNode(BulkIterationNode template, String nodeName, Channel input, BulkPartialSolutionPlanNode pspn, PlanNode rootOfStepFunction)
public BulkIterationPlanNode(BulkIterationNode template, String nodeName, Channel input, BulkPartialSolutionPlanNode pspn, PlanNode rootOfStepFunction, PlanNode rootOfTerminationCriterion)
public BulkIterationNode getIterationNode()
getIterationNode
in interface IterationPlanNode
public BulkPartialSolutionPlanNode getPartialSolutionPlanNode()
public PlanNode getRootOfStepFunction()
public PlanNode getRootOfTerminationCriterion()
public TypeSerializerFactory<?> getSerializerForIterationChannel()
public void setSerializerForIterationChannel(TypeSerializerFactory<?> serializerForIterationChannel)
public void setCosts(Costs nodeCosts)
PlanNode
public int getMemoryConsumerWeight()
getMemoryConsumerWeight
in class PlanNode
public PlanNode.SourceAndDamReport hasDamOnPathDownTo(PlanNode source)
PlanNode
hasDamOnPathDownTo
in class SingleInputPlanNode
source
- The node on the path to which the dam is sought.public void acceptForStepFunction(Visitor<PlanNode> visitor)
acceptForStepFunction
in interface IterationPlanNode
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.