OuterJoinNode (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.OuterJoinNode

All Implemented Interfaces:

EstimateProvider, DumpableNode<OptimizerNode>, org.apache.flink.util.Visitable<OptimizerNode>
```
public class OuterJoinNode
extends TwoInputNode
```

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
`OuterJoinNode(org.apache.flink.api.common.operators.base.OuterJoinOperatorBase<?,?,?,?> operator)`	Creates a new two input node for the optimizer plan, representing the given operator.

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.OuterJoinOperatorBase<?,?,?,?>`	`getOperator()`	Gets the operator represented by this optimizer 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
  - OuterJoinNode
```
public OuterJoinNode(org.apache.flink.api.common.operators.base.OuterJoinOperatorBase<?,?,?,?> operator)
```
    Creates a new two input node for the optimizer plan, representing the given operator.
    
    Parameters:
    
    operator - The operator that the optimizer DAG node should represent.
- Method Detail
  - getOperator
```
public org.apache.flink.api.common.operators.base.OuterJoinOperatorBase<?,?,?,?> getOperator()
```
    Description copied from class: OptimizerNode
    
    Gets the operator represented by this optimizer node.
    
    Overrides:
    
    getOperator in class TwoInputNode
    
    Returns:
    
    This node's operator.
  - getPossibleProperties
```
protected List<OperatorDescriptorDual> getPossibleProperties()
```
    Specified by:
    
    getPossibleProperties in class TwoInputNode
  - 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.
  - computeOperatorSpecificDefaultEstimates
```
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
```
    Specified by:
    
    computeOperatorSpecificDefaultEstimates in class OptimizerNode