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

Class DefaultResourceManager.DefaultResourceAllocator

java.lang.Object

org.apache.drill.exec.work.foreman.rm.DefaultResourceManager.DefaultResourceAllocator

All Implemented Interfaces:

QueryResourceAllocator

Direct Known Subclasses:

DefaultResourceManager.DefaultQueryResourceManager

Enclosing class:

DefaultResourceManager

public static class DefaultResourceManager.DefaultResourceAllocator
extends Object
implements QueryResourceAllocator

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultResourceAllocator(QueryContext queryContext)

Method Summary

Modifier and Type	Method and Description
QueryContext	getQueryContext()
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

Constructor Detail

DefaultResourceAllocator

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