public class CoGroupNode 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 |
---|
CoGroupNode(CoGroupOperatorBase<?,?,?,?> operator) |
Modifier and Type | Method and Description |
---|---|
protected void |
computeOperatorSpecificDefaultEstimates(DataStatistics statistics) |
CoGroupOperatorBase<?,?,?,?> |
getOperator()
Gets the operator for this CoGroup 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() |
protected SemanticProperties |
getSemanticPropertiesForLocalPropertyFiltering() |
void |
makeCoGroupWithSolutionSet(int solutionsetInputIndex) |
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getFirstIncomingConnection, getFirstPredecessorNode, getIncomingConnections, getSecondIncomingConnection, getSecondPredecessorNode, getSemanticProperties, getSemanticPropertiesForGlobalPropertyFiltering, 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 CoGroupNode(CoGroupOperatorBase<?,?,?,?> operator)
public CoGroupOperatorBase<?,?,?,?> getOperator()
getOperator
in class TwoInputNode
public String getOperatorName()
OptimizerNode
getOperatorName
in class OptimizerNode
protected List<OperatorDescriptorDual> getPossibleProperties()
getPossibleProperties
in class TwoInputNode
public void makeCoGroupWithSolutionSet(int solutionsetInputIndex)
protected SemanticProperties getSemanticPropertiesForLocalPropertyFiltering()
getSemanticPropertiesForLocalPropertyFiltering
in class TwoInputNode
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
computeOperatorSpecificDefaultEstimates
in class OptimizerNode
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.