public class SolutionSetNode extends AbstractPartialSolutionNode
OptimizerNode.UnclosedBranchDescriptor
cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields
Constructor and Description |
---|
SolutionSetNode(DeltaIterationBase.SolutionSetPlaceHolder<?> psph,
WorksetIterationNode 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.
|
SolutionSetPlanNode |
getCurrentSolutionSetPlanNode() |
WorksetIterationNode |
getIterationNode() |
DeltaIterationBase.SolutionSetPlaceHolder<?> |
getOperator()
Gets the contract object for this data source 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 SolutionSetNode(DeltaIterationBase.SolutionSetPlaceHolder<?> psph, WorksetIterationNode iterationNode)
public void setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
public SolutionSetPlanNode getCurrentSolutionSetPlanNode()
public WorksetIterationNode 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 DeltaIterationBase.SolutionSetPlaceHolder<?> getOperator()
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–2021 The Apache Software Foundation. All rights reserved.