Uses of Class
org.apache.flink.optimizer.costs.Costs

Packages that use Costs

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

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

Methods in org.apache.flink.optimizer.costs that return Costs

Modifier and Type	Method and Description
Costs	Costs.clone()

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

Modifier and Type	Method and 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.
void	Costs.addCosts(Costs other) Adds the given costs to these costs.
abstract void	CostEstimator.addFileInputCost(long fileSizeInBytes, Costs costs)
void	DefaultCostEstimator.addFileInputCost(long fileSizeInBytes, Costs costs)
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)
int	Costs.compareTo(Costs o) The order of comparison is: network first, then disk, then CPU.
void	Costs.subtractCosts(Costs other) Subtracts the given costs from these costs.

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

Fields in org.apache.flink.optimizer.plan declared as Costs

Modifier and Type	Field and Description
protected Costs	PlanNode.cumulativeCosts
protected Costs	PlanNode.nodeCosts

Methods in org.apache.flink.optimizer.plan that return Costs

Modifier and Type	Method and Description
Costs	PlanNode.getCumulativeCosts() Gets the cumulative costs of this nose.
Costs	PlanNode.getCumulativeCostsShare()
Costs	PlanNode.getNodeCosts() Gets the costs incurred by this node.

Methods in org.apache.flink.optimizer.plan with parameters of type Costs

Modifier and Type	Method and Description
void	PlanNode.setCosts(Costs nodeCosts) Sets the basic cost for this node to the given value, and sets the cumulative costs to those costs plus the cost shares of all inputs (regular and broadcast).
void	BulkIterationPlanNode.setCosts(Costs nodeCosts)
void	SinkJoinerPlanNode.setCosts(Costs nodeCosts)
void	WorksetIterationPlanNode.setCosts(Costs nodeCosts)

Constructors in org.apache.flink.optimizer.plan with parameters of type Costs

Constructor and Description
NAryUnionPlanNode(BinaryUnionNode template, List<Channel> inputs, GlobalProperties gProps, Costs cumulativeCosts)