public class BulkPartialSolutionNode extends AbstractPartialSolutionNode
OptimizerNode.UnclosedBranchDescriptor
cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields
Constructor and Description |
---|
BulkPartialSolutionNode(BulkIterationBase.PartialSolutionPlaceHolder<?> psph,
BulkIterationNode iterationNode) |
Modifier and Type | Method and Description |
---|---|
void |
computeOutputEstimates(DataStatistics statistics)
Causes this node to compute its output estimates (such as number of rows, size in bytes)
based on the inputs and the compiler hints.
|
void |
computeUnclosedBranchStack()
This method causes the node to compute the description of open branches in its sub-plan.
|
BulkPartialSolutionPlanNode |
getCurrentPartialSolutionPlanNode() |
BulkIterationNode |
getIterationNode() |
BulkIterationBase.PartialSolutionPlaceHolder<?> |
getOperator()
Gets the operator (here the
BulkIterationBase.PartialSolutionPlaceHolder ) that is represented by this
optimizer node. |
String |
getOperatorName()
Gets the name of this node, which is the name of the function/operator, or data source / data
sink.
|
void |
setCandidateProperties(GlobalProperties gProps,
LocalProperties lProps,
Channel initialInput) |
accept, computeInterestingPropertiesForInputs, computeOperatorSpecificDefaultEstimates, copyEstimates, getAlternativePlans, getIncomingConnections, getSemanticProperties, identifyDynamicPath, isOnDynamicPath, readStubAnnotations, setInput
addBroadcastConnection, addClosedBranch, addClosedBranches, addOutgoingConnection, areBranchCompatible, clearInterestingProperties, computeUnclosedBranchStackForBroadcastInputs, computeUnionOfInterestingPropertiesFromSuccessors, getBranchesForParent, getBroadcastConnectionNames, getBroadcastConnections, getClosedBranchingNodes, getCostWeight, getDumpableInputs, getEstimatedAvgWidthPerOutputRecord, getEstimatedNumRecords, getEstimatedOutputSize, getId, getInterestingProperties, getMaxDepth, getMinimalMemoryAcrossAllSubTasks, getOpenBranches, getOptimizerNode, getOutgoingConnections, getParallelism, getPlanNode, getPredecessors, getUniqueFields, hasUnclosedBranches, haveAllOutputConnectionInterestingProperties, initId, isBranching, markAllOutgoingConnectionsAsPipelineBreaking, mergeLists, prunePlanAlternatives, prunePlanAlternativesWithCommonBranching, readUniqueFieldsAnnotation, removeClosedBranches, setBroadcastInputs, setEstimatedNumRecords, setEstimatedOutputSize, setParallelism, toString
public BulkPartialSolutionNode(BulkIterationBase.PartialSolutionPlaceHolder<?> psph, BulkIterationNode iterationNode)
public void setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
public BulkPartialSolutionPlanNode getCurrentPartialSolutionPlanNode()
public BulkIterationNode getIterationNode()
getIterationNode
in class AbstractPartialSolutionNode
public void computeOutputEstimates(DataStatistics statistics)
OptimizerNode
computeOutputEstimates
in class OptimizerNode
statistics
- The statistics object which may be accessed to get statistical information.
The parameter may be null, if no statistics are available.public BulkIterationBase.PartialSolutionPlaceHolder<?> getOperator()
BulkIterationBase.PartialSolutionPlaceHolder
) that is represented by this
optimizer node.getOperator
in class OptimizerNode
public String getOperatorName()
OptimizerNode
getOperatorName
in class OptimizerNode
public void computeUnclosedBranchStack()
OptimizerNode
openBranches
field to a stack of unclosed branches, the latest one top. A branch is considered closed, if
some later node sees all of the branching node's outputs, no matter if there have been more
branches to different paths in the meantime.computeUnclosedBranchStack
in class OptimizerNode
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.