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 and 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 and Description
protected PhysicalPlan	plan
protected QueryContext	queryContext
protected double	queryCost
protected ThrottledResourceManager	rm
protected QueryWorkUnit	work

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

rm

protected final ThrottledResourceManager rm

queryContext

protected QueryContext queryContext

plan

protected PhysicalPlan plan

work

protected QueryWorkUnit work

queryCost

protected double queryCost

Constructor Detail

QueuedResourceAllocator

protected QueuedResourceAllocator(ThrottledResourceManager rm,
                                  QueryContext queryContext)

Method Detail

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()