Package org.apache.flink.optimizer.dag
Class CoGroupRawNode
- java.lang.Object
-
- org.apache.flink.optimizer.dag.OptimizerNode
-
- org.apache.flink.optimizer.dag.TwoInputNode
-
- org.apache.flink.optimizer.dag.CoGroupRawNode
-
- All Implemented Interfaces:
EstimateProvider,DumpableNode<OptimizerNode>,org.apache.flink.util.Visitable<OptimizerNode>
public class CoGroupRawNode extends TwoInputNode
The Optimizer representation of a CoGroupRaw operator.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.optimizer.dag.OptimizerNode
OptimizerNode.UnclosedBranchDescriptor
-
-
Field Summary
-
Fields inherited from class org.apache.flink.optimizer.dag.TwoInputNode
input1, input2, keys1, keys2
-
Fields inherited from class org.apache.flink.optimizer.dag.OptimizerNode
cachedPlans, closedBranchingNodes, costWeight, estimatedNumRecords, estimatedOutputSize, hereJoinedBranches, id, MAX_DYNAMIC_PATH_COST_WEIGHT, onDynamicPath, openBranches, uniqueFields
-
-
Constructor Summary
Constructors Constructor Description CoGroupRawNode(org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,?,?> pactContract)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidcomputeOperatorSpecificDefaultEstimates(DataStatistics statistics)org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,?,?>getOperator()Gets the operator for this CoGroup node.StringgetOperatorName()Gets the name of this node, which is the name of the function/operator, or data source / data sink.protected List<OperatorDescriptorDual>getPossibleProperties()-
Methods inherited from class org.apache.flink.optimizer.dag.TwoInputNode
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getFirstIncomingConnection, getFirstPredecessorNode, getIncomingConnections, getSecondIncomingConnection, getSecondPredecessorNode, getSemanticProperties, getSemanticPropertiesForGlobalPropertyFiltering, getSemanticPropertiesForLocalPropertyFiltering, instantiate, placePipelineBreakersIfNecessary, setInput
-
Methods inherited from class org.apache.flink.optimizer.dag.OptimizerNode
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
-
-
-
-
Method Detail
-
getOperator
public org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,?,?> getOperator()
Gets the operator for this CoGroup node.- Overrides:
getOperatorin classTwoInputNode- Returns:
- The CoGroup operator.
-
getOperatorName
public String getOperatorName()
Description copied from class:OptimizerNodeGets the name of this node, which is the name of the function/operator, or data source / data sink.- Specified by:
getOperatorNamein classOptimizerNode- Returns:
- The node name.
-
getPossibleProperties
protected List<OperatorDescriptorDual> getPossibleProperties()
- Specified by:
getPossiblePropertiesin classTwoInputNode
-
computeOperatorSpecificDefaultEstimates
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
- Specified by:
computeOperatorSpecificDefaultEstimatesin classOptimizerNode
-
-