org.apache.drill.exec.resourcemgr.config.selectionpolicy

Class DefaultQueueSelection

java.lang.Object

org.apache.drill.exec.resourcemgr.config.selectionpolicy.AbstractQueueSelectionPolicy

org.apache.drill.exec.resourcemgr.config.selectionpolicy.DefaultQueueSelection

All Implemented Interfaces:

QueueSelectionPolicy

public class DefaultQueueSelection
extends AbstractQueueSelectionPolicy

Helps to select the first default queue in the list of all the provided queues. If there is no default queue present it throws QueueSelectionException. Default queue is a queue associated with ResourcePool which has DefaultSelector assigned to it

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.resourcemgr.config.selectionpolicy.QueueSelectionPolicy

QueueSelectionPolicy.SelectionPolicy

Constructor Summary

Constructors

Constructor and Description
DefaultQueueSelection()

Method Summary

Modifier and Type	Method and Description
ResourcePool	selectQueue(List<ResourcePool> allPools, QueryContext queryContext, NodeResources maxResourcePerNode)

Methods inherited from class org.apache.drill.exec.resourcemgr.config.selectionpolicy.AbstractQueueSelectionPolicy

getSelectionPolicy

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultQueueSelection

public DefaultQueueSelection()

Method Detail

selectQueue

public ResourcePool selectQueue(List<ResourcePool> allPools,
                                QueryContext queryContext,
                                NodeResources maxResourcePerNode)
                         throws QueueSelectionException

Specified by:

selectQueue in interface QueueSelectionPolicy

Specified by:

selectQueue in class AbstractQueueSelectionPolicy

Throws:

QueueSelectionException