Package org.apache.flink.optimizer.dag

Class CrossNode

java.lang.Object

org.apache.flink.optimizer.dag.OptimizerNode

org.apache.flink.optimizer.dag.TwoInputNode

org.apache.flink.optimizer.dag.CrossNode

All Implemented Interfaces:

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

public class CrossNode
extends TwoInputNode

The Optimizer representation of a Cross (Cartesian product) 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
CrossNode(org.apache.flink.api.common.operators.base.CrossOperatorBase<?,?,?,?> operation)	Creates a new CrossNode for the given operator.

Method Summary

Modifier and Type	Method	Description
protected void	computeOperatorSpecificDefaultEstimates(DataStatistics statistics)	We assume that the cardinality is the product of the input cardinalities and that the result width is the sum of the input widths.
org.apache.flink.api.common.operators.base.CrossOperatorBase<?,?,?,?>	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

CrossNode

public CrossNode(org.apache.flink.api.common.operators.base.CrossOperatorBase<?,?,?,?> operation)

Creates a new CrossNode for the given operator.

Parameters:

operation - The Cross operator object.

Method Detail

getOperator

public org.apache.flink.api.common.operators.base.CrossOperatorBase<?,?,?,?> getOperator()

Description copied from class: OptimizerNode

Gets the operator represented by this optimizer node.

Overrides:

getOperator in class TwoInputNode

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<OperatorDescriptorDual> getPossibleProperties()

Specified by:

getPossibleProperties in class TwoInputNode

computeOperatorSpecificDefaultEstimates

protected void computeOperatorSpecificDefaultEstimates(DataStatistics statistics)

We assume that the cardinality is the product of the input cardinalities and that the result width is the sum of the input widths.

Specified by:

computeOperatorSpecificDefaultEstimates in class OptimizerNode

Parameters:

statistics - The statistics object to optionally access.