Uses of Interface
org.apache.flink.optimizer.dag.EstimateProvider

Packages that use EstimateProvider

Package	Description
org.apache.flink.optimizer.costs
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.plan

Uses of EstimateProvider in org.apache.flink.optimizer.costs

Methods in org.apache.flink.optimizer.costs with parameters of type EstimateProvider

Modifier and Type	Method	Description
abstract void	CostEstimator.addArtificialDamCost(EstimateProvider estimates, long bufferSize, Costs costs)
void	DefaultCostEstimator.addArtificialDamCost(EstimateProvider estimates, long bufferSize, Costs costs)
abstract void	CostEstimator.addBlockNestedLoopsCosts(EstimateProvider outerSide, EstimateProvider innerSide, long blockSize, Costs costs, int costWeight)
void	DefaultCostEstimator.addBlockNestedLoopsCosts(EstimateProvider outerSide, EstimateProvider innerSide, long blockSize, Costs costs, int costWeight)
abstract void	CostEstimator.addBroadcastCost(EstimateProvider estimates, int replicationFactor, Costs costs)
void	DefaultCostEstimator.addBroadcastCost(EstimateProvider estimates, int replicationFactor, Costs costs)
abstract void	CostEstimator.addCachedHybridHashCosts(EstimateProvider buildSide, EstimateProvider probeSide, Costs costs, int costWeight)
void	DefaultCostEstimator.addCachedHybridHashCosts(EstimateProvider buildSideInput, EstimateProvider probeSideInput, Costs costs, int costWeight)	Calculates the costs for the cached variant of the hybrid hash join.
abstract void	CostEstimator.addHashPartitioningCost(EstimateProvider estimates, Costs costs)
void	DefaultCostEstimator.addHashPartitioningCost(EstimateProvider estimates, Costs costs)
abstract void	CostEstimator.addHybridHashCosts(EstimateProvider buildSide, EstimateProvider probeSide, Costs costs, int costWeight)
void	DefaultCostEstimator.addHybridHashCosts(EstimateProvider buildSideInput, EstimateProvider probeSideInput, Costs costs, int costWeight)
abstract void	CostEstimator.addLocalMergeCost(EstimateProvider estimates1, EstimateProvider estimates2, Costs costs, int costWeight)
void	DefaultCostEstimator.addLocalMergeCost(EstimateProvider input1, EstimateProvider input2, Costs costs, int costWeight)
abstract void	CostEstimator.addLocalSortCost(EstimateProvider estimates, Costs costs)
void	DefaultCostEstimator.addLocalSortCost(EstimateProvider estimates, Costs costs)
abstract void	CostEstimator.addRandomPartitioningCost(EstimateProvider estimates, Costs costs)
void	DefaultCostEstimator.addRandomPartitioningCost(EstimateProvider estimates, Costs costs)
abstract void	CostEstimator.addRangePartitionCost(EstimateProvider estimates, Costs costs)
void	DefaultCostEstimator.addRangePartitionCost(EstimateProvider estimates, Costs costs)
abstract void	CostEstimator.addStreamedNestedLoopsCosts(EstimateProvider outerSide, EstimateProvider innerSide, long bufferSize, Costs costs, int costWeight)
void	DefaultCostEstimator.addStreamedNestedLoopsCosts(EstimateProvider outerSide, EstimateProvider innerSide, long bufferSize, Costs costs, int costWeight)

Uses of EstimateProvider in org.apache.flink.optimizer.dag

Classes in org.apache.flink.optimizer.dag that implement EstimateProvider

Modifier and Type	Class	Description
class	AbstractPartialSolutionNode	The optimizer's internal representation of the partial solution that is input to a bulk iteration.
class	BinaryUnionNode	The Optimizer representation of a binary Union.
class	BulkIterationNode	A node in the optimizer's program representation for a bulk iteration.
class	BulkPartialSolutionNode	The optimizer's internal representation of the partial solution that is input to a bulk iteration.
class	CoGroupNode	The Optimizer representation of a CoGroup operator.
class	CoGroupRawNode	The Optimizer representation of a CoGroupRaw operator.
class	CrossNode	The Optimizer representation of a Cross (Cartesian product) operator.
class	DagConnection	A connection between two operators.
class	DataSinkNode	The Optimizer representation of a data sink.
class	DataSourceNode	The optimizer's internal representation of a data source.
class	FilterNode	The optimizer's internal representation of a Filter operator node.
class	FlatMapNode	The optimizer's internal representation of a FlatMap operator node.
class	GroupCombineNode	The optimizer representation of a GroupCombineNode operation.
class	GroupReduceNode	The optimizer representation of a GroupReduce operation.
class	JoinNode	The Optimizer representation of a join operator.
class	MapNode	The optimizer's internal representation of a Map operator node.
class	MapPartitionNode	The optimizer's internal representation of a MapPartition operator node.
class	NoOpNode	The optimizer's internal representation of a No Operation node.
class	OptimizerNode	The OptimizerNode is the base class of all nodes in the optimizer DAG.
class	OuterJoinNode
class	PartitionNode	The optimizer's internal representation of a Partition operator node.
class	ReduceNode	The Optimizer representation of a Reduce operator.
class	SingleInputNode	A node in the optimizer's program representation for an operation with a single input.
class	SinkJoiner	This class represents a utility node that is not part of the actual plan.
class	SolutionSetNode	The optimizer's internal representation of the solution set of a workset iteration.
class	SortPartitionNode	The optimizer's internal representation of a SortPartition operator node.
class	TwoInputNode	A node in the optimizer plan that represents an operator with a two different inputs, such as Join, Cross, CoGroup, or Union.
class	UnaryOperatorNode
class	WorksetIterationNode	A node in the optimizer's program representation for a workset iteration.
static class	WorksetIterationNode.SingleRootJoiner
class	WorksetNode	The optimizer's internal representation of the partial solution that is input to a bulk iteration.

Uses of EstimateProvider in org.apache.flink.optimizer.plan

Classes in org.apache.flink.optimizer.plan that implement EstimateProvider

Modifier and Type	Class	Description
class	Channel	A Channel represents the result produced by an operator and the data exchange before the consumption by the target operator.
class	NamedChannel