Package org.apache.wayang.core.optimizer

Class DefaultOptimizationContext

java.lang.Object

org.apache.wayang.core.optimizer.OptimizationContext

org.apache.wayang.core.optimizer.DefaultOptimizationContext

public class DefaultOptimizationContext
extends OptimizationContext

This implementation of OptimizationContext represents a direct mapping from OptimizationContext.OperatorContext to executions of the respective Operators.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.wayang.core.optimizer.OptimizationContext

OptimizationContext.LoopContext, OptimizationContext.OperatorContext

Field Summary

Fields inherited from class org.apache.wayang.core.optimizer.OptimizationContext

hostLoopContext, job, logger

Constructor Summary

Constructors

Constructor	Description
DefaultOptimizationContext(Job job)	Create a new instance.
DefaultOptimizationContext(Job job, Operator operator)	Creates a new instance.
DefaultOptimizationContext(OptimizationContext base)	Forks an DefaultOptimizationContext by providing a write-layer on top of the base.

Method Summary

Modifier and Type	Method	Description
void	addOneTimeLoop(OptimizationContext.OperatorContext operatorContext)	Add DefaultOptimizationContexts for the loop that is executed once within this instance.
OptimizationContext.OperatorContext	addOneTimeOperator(Operator operator)	Add OptimizationContext.OperatorContexts for the operator that is executed once within this instance.
void	clearMarks()	Calls OptimizationContext.OperatorContext.clearMarks() for all nested OptimizationContext.OperatorContexts.
DefaultOptimizationContext	copy()	Create a shallow copy of this instance.
static DefaultOptimizationContext	createFrom(Job job)	Create a new instance and adds all Operators in the WayangPlan.
DefaultOptimizationContext	getBase()
List<DefaultOptimizationContext>	getDefaultOptimizationContexts()	Get the DefaultOptimizationContexts represented by this instance.
Map<Operator,OptimizationContext.OperatorContext>	getLocalOperatorContexts()
OptimizationContext.LoopContext	getNestedLoopContext(LoopSubplan loopSubplan)	Retrieve the OptimizationContext.LoopContext for the loopSubplan.
OptimizationContext.OperatorContext	getOperatorContext(Operator operator)	Return the OptimizationContext.OperatorContext of the operator.
boolean	isTimeEstimatesComplete()
void	mergeToBase()

Methods inherited from class org.apache.wayang.core.optimizer.OptimizationContext

addOneTimeOperators, getChannelConversionGraph, getConfiguration, getIterationNumber, getJob, getLoopContext, getNextIterationContext, getParent, getPruningStrategies, getRootParent, isFinalIteration, isInitialIteration, putIntoJobCache, queryJobCache, queryJobCache

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultOptimizationContext

public DefaultOptimizationContext(Job job)

Create a new instance.

Parameters:

job - the optimization task; loops should already be isolated

DefaultOptimizationContext

public DefaultOptimizationContext(OptimizationContext base)

Forks an DefaultOptimizationContext by providing a write-layer on top of the base.

DefaultOptimizationContext

public DefaultOptimizationContext(Job job,
 Operator operator)

Creates a new instance. Useful for testing.

Parameters:

job - whose optimization thew new instance backs

operator - the single Operator of this instance

Method Details

createFrom

public static DefaultOptimizationContext createFrom(Job job)

Create a new instance and adds all Operators in the WayangPlan.

Parameters:

job - the optimization task; loops should already be isolated

addOneTimeOperator

public OptimizationContext.OperatorContext addOneTimeOperator(Operator operator)

Description copied from class: OptimizationContext

Add OptimizationContext.OperatorContexts for the operator that is executed once within this instance. Also add its encased Operators. Potentially invoke OptimizationContext.addOneTimeLoop(OperatorContext) as well.

Specified by:

addOneTimeOperator in class OptimizationContext

addOneTimeLoop

public void addOneTimeLoop(OptimizationContext.OperatorContext operatorContext)

Add DefaultOptimizationContexts for the loop that is executed once within this instance.

Specified by:

addOneTimeLoop in class OptimizationContext

getOperatorContext

public OptimizationContext.OperatorContext getOperatorContext(Operator operator)

Return the OptimizationContext.OperatorContext of the operator.

Specified by:

getOperatorContext in class OptimizationContext

Parameters:

operator - a one-time Operator (i.e., not in a nested loop)

Returns:

the OptimizationContext.OperatorContext for the Operator or null if none

getNestedLoopContext

public OptimizationContext.LoopContext getNestedLoopContext(LoopSubplan loopSubplan)

Retrieve the OptimizationContext.LoopContext for the loopSubplan.

Specified by:

getNestedLoopContext in class OptimizationContext

clearMarks

public void clearMarks()

Calls OptimizationContext.OperatorContext.clearMarks() for all nested OptimizationContext.OperatorContexts.

Specified by:

clearMarks in class OptimizationContext

getLocalOperatorContexts

public Map<Operator,OptimizationContext.OperatorContext> getLocalOperatorContexts()

Specified by:

getLocalOperatorContexts in class OptimizationContext

Returns:

the OptimizationContext.OperatorContexts of this instance (exclusive of any base instance)

isTimeEstimatesComplete

public boolean isTimeEstimatesComplete()

Specified by:

isTimeEstimatesComplete in class OptimizationContext

Returns:

whether there is a TimeEstimate for each ExecutionOperator

getBase

public DefaultOptimizationContext getBase()

Overrides:

getBase in class OptimizationContext

mergeToBase

public void mergeToBase()

Specified by:

mergeToBase in class OptimizationContext

getDefaultOptimizationContexts

public List<DefaultOptimizationContext> getDefaultOptimizationContexts()

Description copied from class: OptimizationContext

Get the DefaultOptimizationContexts represented by this instance.

Specified by:

getDefaultOptimizationContexts in class OptimizationContext

Returns:

a Collection of said DefaultOptimizationContexts

copy

public DefaultOptimizationContext copy()

Create a shallow copy of this instance.

Returns:

the shallow copy