Package | Description |
---|---|
org.apache.flink.optimizer.costs | |
org.apache.flink.optimizer.plan |
Modifier and Type | Method and Description |
---|---|
Costs |
Costs.clone() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultCostEstimator.addArtificialDamCost(EstimateProvider estimates,
long bufferSize,
Costs costs) |
abstract void |
CostEstimator.addArtificialDamCost(EstimateProvider estimates,
long bufferSize,
Costs costs) |
void |
DefaultCostEstimator.addBlockNestedLoopsCosts(EstimateProvider outerSide,
EstimateProvider innerSide,
long blockSize,
Costs costs,
int costWeight) |
abstract void |
CostEstimator.addBlockNestedLoopsCosts(EstimateProvider outerSide,
EstimateProvider innerSide,
long blockSize,
Costs costs,
int costWeight) |
void |
DefaultCostEstimator.addBroadcastCost(EstimateProvider estimates,
int replicationFactor,
Costs costs) |
abstract void |
CostEstimator.addBroadcastCost(EstimateProvider estimates,
int replicationFactor,
Costs costs) |
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.addCachedHybridHashCosts(EstimateProvider buildSide,
EstimateProvider probeSide,
Costs costs,
int costWeight) |
void |
Costs.addCosts(Costs other)
Adds the given costs to these costs.
|
void |
DefaultCostEstimator.addFileInputCost(long fileSizeInBytes,
Costs costs) |
abstract void |
CostEstimator.addFileInputCost(long fileSizeInBytes,
Costs costs) |
void |
DefaultCostEstimator.addHashPartitioningCost(EstimateProvider estimates,
Costs costs) |
abstract void |
CostEstimator.addHashPartitioningCost(EstimateProvider estimates,
Costs costs) |
void |
DefaultCostEstimator.addHybridHashCosts(EstimateProvider buildSideInput,
EstimateProvider probeSideInput,
Costs costs,
int costWeight) |
abstract void |
CostEstimator.addHybridHashCosts(EstimateProvider buildSide,
EstimateProvider probeSide,
Costs costs,
int costWeight) |
void |
DefaultCostEstimator.addLocalMergeCost(EstimateProvider input1,
EstimateProvider input2,
Costs costs,
int costWeight) |
abstract void |
CostEstimator.addLocalMergeCost(EstimateProvider estimates1,
EstimateProvider estimates2,
Costs costs,
int costWeight) |
void |
DefaultCostEstimator.addLocalSortCost(EstimateProvider estimates,
Costs costs) |
abstract void |
CostEstimator.addLocalSortCost(EstimateProvider estimates,
Costs costs) |
void |
DefaultCostEstimator.addRandomPartitioningCost(EstimateProvider estimates,
Costs costs) |
abstract void |
CostEstimator.addRandomPartitioningCost(EstimateProvider estimates,
Costs costs) |
void |
DefaultCostEstimator.addRangePartitionCost(EstimateProvider estimates,
Costs costs) |
abstract void |
CostEstimator.addRangePartitionCost(EstimateProvider estimates,
Costs costs) |
void |
DefaultCostEstimator.addStreamedNestedLoopsCosts(EstimateProvider outerSide,
EstimateProvider innerSide,
long bufferSize,
Costs costs,
int costWeight) |
abstract void |
CostEstimator.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.
|
Modifier and Type | Field and Description |
---|---|
protected Costs |
PlanNode.cumulativeCosts |
protected Costs |
PlanNode.nodeCosts |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
WorksetIterationPlanNode.setCosts(Costs nodeCosts) |
void |
SinkJoinerPlanNode.setCosts(Costs nodeCosts) |
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) |
Constructor and Description |
---|
NAryUnionPlanNode(BinaryUnionNode template,
List<Channel> inputs,
GlobalProperties gProps,
Costs cumulativeCosts) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.