MapNode (Flink : Optimizer 1.19.2-cp2 API)

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

All Implemented Interfaces:

EstimateProvider, DumpableNode<OptimizerNode>, org.apache.flink.util.Visitable<OptimizerNode>
```
public class MapNode
extends SingleInputNode
```
The optimizer's internal representation of a Map 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

MapNode(org.apache.flink.api.common.operators.SingleInputOperator<?,?,?> operator)
Creates a new MapNode for the given operator.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`computeOperatorSpecificDefaultEstimates(DataStatistics statistics)`	Computes the estimates for the Map operator.
`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, getOperator, 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
  - MapNode
```
public MapNode(org.apache.flink.api.common.operators.SingleInputOperator<?,?,?> operator)
```
    Creates a new MapNode for the given operator.
    
    Parameters:
    
    operator - The map operator.
- Method Detail
  - 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 Map operator. We assume that by default, Map takes one value and transforms it into another value. The cardinality consequently stays the same.
    
    Specified by:
    
    computeOperatorSpecificDefaultEstimates in class OptimizerNode