Package org.apache.wayang.core.optimizer.costs

Class DefaultEstimatableCost

java.lang.Object

org.apache.wayang.core.optimizer.costs.DefaultEstimatableCost

All Implemented Interfaces:

EstimatableCost

public class DefaultEstimatableCost
extends Object
implements EstimatableCost

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultEstimatableCost.Factory

Field Summary

Fields

Modifier and Type	Field	Description
static EstimatableCostFactory	FACTORY

Constructor Summary

Constructors

Constructor	Description
DefaultEstimatableCost()

Method Summary

Modifier and Type	Method	Description
ProbabilisticDoubleInterval	getEstimate(PlanImplementation plan, boolean isIncludeOverhead)	Retrieves the cost estimate for this instance including any overhead.
EstimatableCostFactory	getFactory()
ProbabilisticDoubleInterval	getParallelEstimate(PlanImplementation plan, boolean isIncludeOverhead)	Retrieves the cost estimate for this instance taking into account parallel stage execution.
Tuple<List<ProbabilisticDoubleInterval>,List<Double>>	getParallelOperatorJunctionAllCostEstimate(PlanImplementation plan, Operator operator)	Retrieves the cost estimate of input Operator and input Junction and recurse if there is input Operators
double	getSquashedEstimate(PlanImplementation plan, boolean isIncludeOverhead)	Retrieves the cost estimate for this instance.
double	getSquashedParallelEstimate(PlanImplementation plan, boolean isIncludeOverhead)	Retrieves the cost estimate for this instance taking into account parallel stage execution.
PlanImplementation	pickBestExecutionPlan(Collection<PlanImplementation> executionPlans, ExecutionPlan existingPlan, Set<Channel> openChannels, Set<ExecutionStage> executedStages)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

FACTORY

public static EstimatableCostFactory FACTORY

Constructor Details

DefaultEstimatableCost

public DefaultEstimatableCost()

Method Details

pickBestExecutionPlan

public PlanImplementation pickBestExecutionPlan(Collection<PlanImplementation> executionPlans,
 ExecutionPlan existingPlan,
 Set<Channel> openChannels,
 Set<ExecutionStage> executedStages)

Specified by:

pickBestExecutionPlan in interface EstimatableCost

getEstimate

public ProbabilisticDoubleInterval getEstimate(PlanImplementation plan,
 boolean isIncludeOverhead)

Retrieves the cost estimate for this instance including any overhead.

Specified by:

getEstimate in interface EstimatableCost

Returns:

the cost estimate

getSquashedEstimate

public double getSquashedEstimate(PlanImplementation plan,
 boolean isIncludeOverhead)

Retrieves the cost estimate for this instance.

Specified by:

getSquashedEstimate in interface EstimatableCost

Parameters:

isIncludeOverhead - whether to include global overhead in the TimeEstimate (to avoid repeating overhead in nested instances)

Returns:

the squashed cost estimate

getParallelEstimate

public ProbabilisticDoubleInterval getParallelEstimate(PlanImplementation plan,
 boolean isIncludeOverhead)

Retrieves the cost estimate for this instance taking into account parallel stage execution.

Specified by:

getParallelEstimate in interface EstimatableCost

Parameters:

isIncludeOverhead - whether to include global overhead in the TimeEstimate (to avoid repeating overhead in nested instances)

Returns:

the cost estimate taking into account parallel stage execution

getSquashedParallelEstimate

public double getSquashedParallelEstimate(PlanImplementation plan,
 boolean isIncludeOverhead)

Retrieves the cost estimate for this instance taking into account parallel stage execution.

Specified by:

getSquashedParallelEstimate in interface EstimatableCost

Parameters:

isIncludeOverhead - whether to include global overhead in the TimeEstimate (to avoid repeating overhead in nested instances)

Returns:

the squashed cost estimate taking into account parallel stage execution

getParallelOperatorJunctionAllCostEstimate

public Tuple<List<ProbabilisticDoubleInterval>,List<Double>> getParallelOperatorJunctionAllCostEstimate(PlanImplementation plan,
 Operator operator)

Retrieves the cost estimate of input Operator and input Junction and recurse if there is input Operators

Specified by:

getParallelOperatorJunctionAllCostEstimate in interface EstimatableCost

Parameters:

operator - Operator that will be used to retreive the cost/squashed costs

Returns:

list of probabilisticDoubleInterval where First element is the operator cost and second element is the junction cost; and list of double retreived where First element is the operator squashed cost and second element is the junction squashed cost

PS: This function will start with the sink operator

getFactory

public EstimatableCostFactory getFactory()

Specified by:

getFactory in interface EstimatableCost