Package org.apache.drill.exec.resourcemgr.config

Interface QueryQueueConfig

All Known Implementing Classes:
QueryQueueConfigImpl
public interface QueryQueueConfig
Interface which defines an implementation for managing queue configuration of a leaf ResourcePool

  • Method Details

    • getQueueId

      String getQueueId()

    • getQueueName

      String getQueueName()

    • getQueueTotalMemoryInMB

      long getQueueTotalMemoryInMB(int numClusterNodes)
      Given number of available nodes in the cluster what is the total memory resource share of this queue cluster wide
      Parameters:
      numClusterNodes - number of available cluster nodes
      Returns:
      Queue's total cluster memory resource share

    • getMaxQueryMemoryInMBPerNode

      long getMaxQueryMemoryInMBPerNode()
      Returns:
      Maximum query memory (in MB) that a query in this queue can consume on a node

    • getMaxQueryTotalMemoryInMB

      long getMaxQueryTotalMemoryInMB(int numClusterNodes)
      Given number of available nodes in the cluster what is the max memory in MB a query in this queue can be assigned cluster wide
      Parameters:
      numClusterNodes - number of available cluster nodes
      Returns:
      Maximum query memory (in MB) in this queue

    • waitForPreferredNodes

      boolean waitForPreferredNodes()
      Determines if admitted queries in this queue should wait in the queue if resources on the preferred assigned nodes of a query determined by planner is unavailable.
      Returns:
      true indicates an admitted query to wait until resources on all the preferred nodes are available or wait until timeout is reached, false indicates an admitted query to not wait and find other nodes with available resources if resources on a preferred node is unavailable.

    • getMaxAdmissibleQueries

      int getMaxAdmissibleQueries()
      Returns:
      Maximum number of queries that can be admitted in the queue

    • getMaxWaitingQueries

      int getMaxWaitingQueries()
      Returns:
      Maximum number of queries that will be allowed to wait in the queue before failing a query right away

    • getWaitTimeoutInMs

      int getWaitTimeoutInMs()
      Returns:
      Maximum time in milliseconds for which a query can be in waiting state inside a queue