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

Class DistributedResourceManager

java.lang.Object

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

All Implemented Interfaces:

ResourceManager

public class DistributedResourceManager
extends Object
implements ResourceManager

Constructor Summary

Constructors

Constructor	Description
DistributedResourceManager(DrillbitContext context)

Method Summary

Modifier and Type	Method	Description
void	close()
int	cpusPerNode()
ResourcePoolTree	getRmPoolTree()
long	memoryPerNode()	Returns the memory, in bytes, assigned to each node in a Drill cluster.
QueryResourceManager	newQueryRM(Foreman foreman)	Create a resource manager to execute a query.
QueryResourceAllocator	newResourceAllocator(QueryContext queryContext)	Create a resource manager to prepare or describe a query.

Methods inherited from class java.lang.Object

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

Constructor Details

DistributedResourceManager

public DistributedResourceManager(DrillbitContext context)
                           throws DrillRuntimeException

Throws:

DrillRuntimeException

Method Details

memoryPerNode

public long memoryPerNode()

Description copied from interface: ResourceManager

Returns the memory, in bytes, assigned to each node in a Drill cluster. Drill requires that nodes are symmetrical. So, knowing the memory on any one node also gives the memory on all other nodes.

Specified by:

memoryPerNode in interface ResourceManager

Returns:

the memory, in bytes, available in each Drillbit

cpusPerNode

public int cpusPerNode()

Specified by:

cpusPerNode in interface ResourceManager

newResourceAllocator

public QueryResourceAllocator newResourceAllocator(QueryContext queryContext)

Description copied from interface: ResourceManager

Create a resource manager to prepare or describe a query. In this form, no queuing is done, but the plan is created as if queuing had been done. Used when executing EXPLAIN PLAN.

Specified by:

newResourceAllocator in interface ResourceManager

Returns:

a resource manager for the query

newQueryRM

public QueryResourceManager newQueryRM(Foreman foreman)

Description copied from interface: ResourceManager

Create a resource manager to execute a query.

Specified by:

newQueryRM in interface ResourceManager

Parameters:

foreman - Foreman which manages the execution

Returns:

a resource manager for the query

getRmPoolTree

public ResourcePoolTree getRmPoolTree()

close

public void close()

Specified by:

close in interface ResourceManager