CoGroupRawNode (Flink : Optimizer 1.19.2-cp2 API)

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 void`	`computeOperatorSpecificDefaultEstimates(DataStatistics statistics)`
`org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,?,?>`	`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()`

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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - CoGroupRawNode
```
public CoGroupRawNode(org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,?,?> pactContract)
```
- Method Detail
  - getOperator
```
public org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,?,?> getOperator()
```
    Gets the operator for this CoGroup node.
    
    Overrides:
    
    getOperator in class TwoInputNode
    
    Returns:
    
    The CoGroup operator.
  - getOperatorName
```
public String getOperatorName()
```
    Description copied from class: OptimizerNode
    
    Gets the name of this node, which is the name of the function/operator, or data source / data sink.
    
    Specified by:
    
    getOperatorName in class OptimizerNode
    
    Returns:
    
    The node name.
  - getPossibleProperties
```
protected List<OperatorDescriptorDual> getPossibleProperties()
```
    Specified by:
    
    getPossibleProperties in class TwoInputNode
  - computeOperatorSpecificDefaultEstimates
```
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
```
    Specified by:
    
    computeOperatorSpecificDefaultEstimates in class OptimizerNode