FlatMapNode (Flink : Optimizer 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.optimizer.dag.OptimizerNode
- - org.apache.flink.optimizer.dag.SingleInputNode
  - - org.apache.flink.optimizer.dag.FlatMapNode

All Implemented Interfaces:

EstimateProvider, DumpableNode<OptimizerNode>, org.apache.flink.util.Visitable<OptimizerNode>
```
public class FlatMapNode
extends SingleInputNode
```
The optimizer's internal representation of a FlatMap operator node.

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.SingleInputNode
  inConn, keys
- 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

FlatMapNode(org.apache.flink.api.common.operators.base.FlatMapOperatorBase<?,?,?> operator)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`computeOperatorSpecificDefaultEstimates(DataStatistics statistics)`	Computes the estimates for the FlatMap operator.
`org.apache.flink.api.common.operators.base.FlatMapOperatorBase<?,?,?>`	`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<OperatorDescriptorSingle>`	`getPossibleProperties()`

Methods inherited from class org.apache.flink.optimizer.dag.SingleInputNode
accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getIncomingConnection, getIncomingConnections, getPredecessorNode, getSemanticProperties, getSemanticPropertiesForGlobalPropertyFiltering, getSemanticPropertiesForLocalPropertyFiltering, instantiateCandidate, setIncomingConnection, 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
  - FlatMapNode
```
public FlatMapNode(org.apache.flink.api.common.operators.base.FlatMapOperatorBase<?,?,?> operator)
```
- Method Detail
  - getOperator
```
public org.apache.flink.api.common.operators.base.FlatMapOperatorBase<?,?,?> getOperator()
```
    Description copied from class: OptimizerNode
    
    Gets the operator represented by this optimizer node.
    
    Overrides:
    
    getOperator in class SingleInputNode
    
    Returns:
    
    This node's 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<OperatorDescriptorSingle> getPossibleProperties()
```
    Specified by:
    
    getPossibleProperties in class SingleInputNode
  - computeOperatorSpecificDefaultEstimates
```
protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)
```
    Computes the estimates for the FlatMap operator. Since it un-nests, we assume a cardinality increase. To give the system a hint at data increase, we take a default magic number of a 5 times increase.
    
    Specified by:
    
    computeOperatorSpecificDefaultEstimates in class OptimizerNode