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

Provides resource management and queuing support for the Drill foreman.

See: Description

Interface Summary

Interface	Description
DistributedQueryQueue.StatusAdapter
QueryQueue	Interface which defines a queue implementation for query queues.
QueryQueue.QueueLease	The opaque lease returned once a query is admitted for execution.
QueryResourceAllocator	Manages resources for an individual query in conjunction with the global ResourceManager.
QueryResourceManager	Extends a QueryResourceAllocator to provide queueing support.
ResourceManager	Drillbit-wide resource manager shared by all queries.

Class Summary

Class	Description
AbstractResourceManager	Abstract base class for a resource manager.
DefaultResourceManager	Represents a default resource manager for clusters that do not provide query queues.
DefaultResourceManager.DefaultQueryResourceManager
DefaultResourceManager.DefaultResourceAllocator
DistributedQueryQueue	Distributed query queue which uses a Zookeeper distributed semaphore to control queuing across the cluster.
DistributedQueryQueue.ZKQueueInfo	Exposes a snapshot of internal state information for use in status reporting, such as in the UI.
DistributedResourceManager
DynamicResourceManager	Wrapper around the default and/or distributed resource managers to allow dynamically enabling and disabling queueing.
EmbeddedQueryQueue	Query queue to be used in an embedded Drillbit.
ResourceManagerBuilder	Builds the proper resource manager and queue implementation for the configured system options.
ThrottledResourceManager	Global resource manager that provides basic admission control (AC) via a configured queue: either the Zookeeper-based distributed queue or the in-process embedded Drillbit queue.
ThrottledResourceManager.QueuedQueryResourceManager	Per-query resource manager.
ThrottledResourceManager.QueuedResourceAllocator
ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder	Searches a fragment operator tree to find buffered within that fragment.

Exception Summary

Exception	Description
QueryQueue.QueryQueueException	Exception thrown for all non-timeout error conditions.
QueryQueue.QueueTimeoutException	Exception thrown if a query exceeds the configured wait time in the query queue.

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

Provides resource management and queuing support for the Drill foreman. The resource manager tracks total resources available to Drill. Several implementations are available: a default implementation for systems without queueing and an access-controlled (AC) version for systems with queues.

Each resource manager provides a per-query manager that is responsible for queuing the query (if needed) and memory allocation to the query based on query characteristics and memory assigned to the query.

Provides two different queue implementations. A distributed ZooKeeper queue and a local queue useful for embedded Drillbits (and for testing.)