public class UnaryOperatorNode extends SingleInputNode
OptimizerNode.UnclosedBranchDescriptor
inConn, keys
cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields
Constructor and Description |
---|
UnaryOperatorNode(String name,
FieldSet keys,
List<OperatorDescriptorSingle> operators) |
UnaryOperatorNode(String name,
FieldSet keys,
OperatorDescriptorSingle... operators) |
UnaryOperatorNode(String name,
SingleInputOperator<?,?,?> operator,
boolean onDynamicPath) |
Modifier and Type | Method and Description |
---|---|
protected void |
computeOperatorSpecificDefaultEstimates(DataStatistics statistics) |
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() |
SemanticProperties |
getSemanticProperties() |
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getIncomingConnection, getIncomingConnections, getOperator, getPredecessorNode, getSemanticPropertiesForGlobalPropertyFiltering, getSemanticPropertiesForLocalPropertyFiltering, 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 UnaryOperatorNode(String name, SingleInputOperator<?,?,?> operator, boolean onDynamicPath)
public UnaryOperatorNode(String name, FieldSet keys, OperatorDescriptorSingle... operators)
public UnaryOperatorNode(String name, FieldSet keys, List<OperatorDescriptorSingle> operators)
protected List<OperatorDescriptorSingle> getPossibleProperties()
getPossibleProperties
in class SingleInputNode
public String getOperatorName()
OptimizerNode
getOperatorName
in class OptimizerNode
public SemanticProperties getSemanticProperties()
getSemanticProperties
in class SingleInputNode
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
computeOperatorSpecificDefaultEstimates
in class OptimizerNode
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.