public class MapPartitionNode extends SingleInputNode
OptimizerNode.UnclosedBranchDescriptor
inConn, keys
cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields
Constructor and Description |
---|
MapPartitionNode(SingleInputOperator<?,?,?> operator)
Creates a new MapNode for the given contract.
|
Modifier and Type | Method and Description |
---|---|
protected void |
computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
Computes the estimates for the MapPartition operator.
|
String |
getOperatorName()
Gets the name of this node, which is the name of the function/operator, or data source / data
sink.
|
protected List<OperatorDescriptorSingle> |
getPossibleProperties() |
protected SemanticProperties |
getSemanticPropertiesForLocalPropertyFiltering() |
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getIncomingConnection, getIncomingConnections, getOperator, getPredecessorNode, getSemanticProperties, getSemanticPropertiesForGlobalPropertyFiltering, instantiateCandidate, setIncomingConnection, 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 MapPartitionNode(SingleInputOperator<?,?,?> operator)
operator
- The map partition contract object.public String getOperatorName()
OptimizerNode
getOperatorName
in class OptimizerNode
protected List<OperatorDescriptorSingle> getPossibleProperties()
getPossibleProperties
in class SingleInputNode
protected SemanticProperties getSemanticPropertiesForLocalPropertyFiltering()
getSemanticPropertiesForLocalPropertyFiltering
in class SingleInputNode
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
computeOperatorSpecificDefaultEstimates
in class OptimizerNode
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.