Package org.apache.drill.exec.work.foreman.rm

Class ThrottledResourceManager.QueuedResourceAllocator

java.lang.Object

org.apache.drill.exec.work.foreman.rm.ThrottledResourceManager.QueuedResourceAllocator

All Implemented Interfaces:

QueryResourceAllocator

Direct Known Subclasses:

ThrottledResourceManager.QueuedQueryResourceManager

Enclosing class:

ThrottledResourceManager

public static class ThrottledResourceManager.QueuedResourceAllocator
extends Object
implements QueryResourceAllocator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder	Searches a fragment operator tree to find buffered within that fragment.

Field Summary

Fields

Modifier and Type	Field	Description
protected PhysicalPlan	plan
protected QueryContext	queryContext
protected double	queryCost
protected final ThrottledResourceManager	rm
protected QueryWorkUnit	work

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	QueuedResourceAllocator(ThrottledResourceManager rm, QueryContext queryContext)

Method Summary

Modifier and Type	Method	Description
QueryContext	getQueryContext()
protected long	queryMemoryPerNode()
void	visitAbstractPlan(PhysicalPlan plan)	Make any needed adjustments to the query plan before parallelization.
void	visitPhysicalPlan(QueryWorkUnit work)	Provide the manager with the physical plan and node assignments for the query to be run.

Methods inherited from class java.lang.Object

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

Field Details

rm

protected final ThrottledResourceManager rm

queryContext

protected QueryContext queryContext

plan

protected PhysicalPlan plan

work

protected QueryWorkUnit work

queryCost

protected double queryCost

Constructor Details

QueuedResourceAllocator

protected QueuedResourceAllocator(ThrottledResourceManager rm,
 QueryContext queryContext)

Method Details

visitAbstractPlan

public void visitAbstractPlan(PhysicalPlan plan)

Description copied from interface: QueryResourceAllocator

Make any needed adjustments to the query plan before parallelization.

Specified by:

visitAbstractPlan in interface QueryResourceAllocator

Parameters:

plan - physical plan

visitPhysicalPlan

public void visitPhysicalPlan(QueryWorkUnit work)

Description copied from interface: QueryResourceAllocator

Provide the manager with the physical plan and node assignments for the query to be run. This class will plan memory for the query.

Specified by:

visitPhysicalPlan in interface QueryResourceAllocator

Parameters:

work - query work unit

getQueryContext

public QueryContext getQueryContext()

queryMemoryPerNode

protected long queryMemoryPerNode()