Package org.apache.flink.optimizer.dag

Class MapPartitionNode

java.lang.Object

org.apache.flink.optimizer.dag.OptimizerNode

org.apache.flink.optimizer.dag.SingleInputNode

org.apache.flink.optimizer.dag.MapPartitionNode

All Implemented Interfaces:

EstimateProvider, DumpableNode<OptimizerNode>, org.apache.flink.util.Visitable<OptimizerNode>

public class MapPartitionNode
extends SingleInputNode

The optimizer's internal representation of a MapPartition 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
MapPartitionNode(org.apache.flink.api.common.operators.SingleInputOperator<?,?,?> operator)	Creates a new MapNode for the given contract.

Method Summary

Modifier and Type	Method	Description
protected void	computeOperatorSpecificDefaultEstimates(DataStatistics statistics)	Computes the estimates for the MapPartition 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()
protected org.apache.flink.api.common.operators.SemanticProperties	getSemanticPropertiesForLocalPropertyFiltering()

Methods inherited from class org.apache.flink.optimizer.dag.SingleInputNode

accept, addLocalCandidates, computeInterestingPropertiesForInputs, computeUnclosedBranchStack, getAlternativePlans, getIncomingConnection, getIncomingConnections, getOperator, getPredecessorNode, getSemanticProperties, getSemanticPropertiesForGlobalPropertyFiltering, 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

MapPartitionNode

public MapPartitionNode(org.apache.flink.api.common.operators.SingleInputOperator<?,?,?> operator)

Creates a new MapNode for the given contract.

Parameters:

operator - The map partition contract object.

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

getSemanticPropertiesForLocalPropertyFiltering

protected org.apache.flink.api.common.operators.SemanticProperties getSemanticPropertiesForLocalPropertyFiltering()

Overrides:

getSemanticPropertiesForLocalPropertyFiltering in class SingleInputNode

computeOperatorSpecificDefaultEstimates

protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)

Computes the estimates for the MapPartition 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