public class CrossNode extends TwoInputNode
OptimizerNode.UnclosedBranchDescriptor
input1, input2, keys1, keys2
cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields
Constructor and Description |
---|
CrossNode(CrossOperatorBase<?,?,?,?> operation)
Creates a new CrossNode for the given operator.
|
Modifier and Type | Method and Description |
---|---|
protected void |
computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
We assume that the cardinality is the product of the input cardinalities and that the result
width is the sum of the input widths.
|
CrossOperatorBase<?,?,?,?> |
getOperator()
Gets the operator 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.
|
protected List<OperatorDescriptorDual> |
getPossibleProperties() |
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getFirstIncomingConnection, getFirstPredecessorNode, getIncomingConnections, getSecondIncomingConnection, getSecondPredecessorNode, getSemanticProperties, getSemanticPropertiesForGlobalPropertyFiltering, getSemanticPropertiesForLocalPropertyFiltering, instantiate, placePipelineBreakersIfNecessary, setInput
addBroadcastConnection, addClosedBranch, addClosedBranches, addOutgoingConnection, areBranchCompatible, clearInterestingProperties, computeOutputEstimates, computeUnclosedBranchStackForBroadcastInputs, computeUnionOfInterestingPropertiesFromSuccessors, getBranchesForParent, getBroadcastConnectionNames, getBroadcastConnections, getClosedBranchingNodes, getCostWeight, getDumpableInputs, getEstimatedAvgWidthPerOutputRecord, getEstimatedNumRecords, getEstimatedOutputSize, getId, getInterestingProperties, getMaxDepth, getMinimalMemoryAcrossAllSubTasks, getOpenBranches, getOptimizerNode, getOutgoingConnections, getParallelism, getPlanNode, getPredecessors, getUniqueFields, hasUnclosedBranches, haveAllOutputConnectionInterestingProperties, identifyDynamicPath, initId, isBranching, isOnDynamicPath, markAllOutgoingConnectionsAsPipelineBreaking, mergeLists, prunePlanAlternatives, prunePlanAlternativesWithCommonBranching, readStubAnnotations, readUniqueFieldsAnnotation, removeClosedBranches, setBroadcastInputs, setEstimatedNumRecords, setEstimatedOutputSize, setParallelism, toString
public CrossNode(CrossOperatorBase<?,?,?,?> operation)
operation
- The Cross operator object.public CrossOperatorBase<?,?,?,?> getOperator()
OptimizerNode
getOperator
in class TwoInputNode
public String getOperatorName()
OptimizerNode
getOperatorName
in class OptimizerNode
protected List<OperatorDescriptorDual> getPossibleProperties()
getPossibleProperties
in class TwoInputNode
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
computeOperatorSpecificDefaultEstimates
in class OptimizerNode
statistics
- The statistics object to optionally access.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.