Package org.apache.wayang.core.optimizer

Class AggregateOptimizationContext

java.lang.Object

org.apache.wayang.core.optimizer.OptimizationContext

org.apache.wayang.core.optimizer.AggregateOptimizationContext

public class AggregateOptimizationContext
extends OptimizationContext

This OptimizationContext implementation aggregates several OptimizationContexts and exposes their OptimizationContext.OperatorContext in an aggregated manner.

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
AggregateOptimizationContext(OptimizationContext.LoopContext loopContext)

Method Summary

Modifier and Type	Method	Description
void	addOneTimeLoop(OptimizationContext.OperatorContext operatorContext)	Add OptimizationContexts 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.
java.util.List<DefaultOptimizationContext>	getDefaultOptimizationContexts()	Get the DefaultOptimizationContexts represented by this instance.
java.util.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()
void	updateOperatorContexts()	This instance caches for efficiency reasons the aggregated OptimizationContext.OperatorContexts.

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

addOneTimeOperators, getBase, 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 Detail

AggregateOptimizationContext

public AggregateOptimizationContext(OptimizationContext.LoopContext loopContext)

Method Detail

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)

Description copied from class: OptimizationContext

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

Specified by:

addOneTimeLoop in class OptimizationContext

getOperatorContext

public OptimizationContext.OperatorContext getOperatorContext(Operator operator)

Description copied from class: OptimizationContext

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

updateOperatorContexts

public void updateOperatorContexts()

This instance caches for efficiency reasons the aggregated OptimizationContext.OperatorContexts. This method causes a re-calculation of this cache.

getNestedLoopContext

public OptimizationContext.LoopContext getNestedLoopContext(LoopSubplan loopSubplan)

Description copied from class: OptimizationContext

Retrieve the OptimizationContext.LoopContext for the loopSubplan.

Specified by:

getNestedLoopContext in class OptimizationContext

clearMarks

public void clearMarks()

Description copied from class: OptimizationContext

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

Specified by:

clearMarks in class OptimizationContext

getLocalOperatorContexts

public java.util.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

mergeToBase

public void mergeToBase()

Specified by:

mergeToBase in class OptimizationContext

getDefaultOptimizationContexts

public java.util.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