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 Summary

Modifier and Type	Method and Description
int	getMaxAdmissibleQueries()
long	getMaxQueryMemoryInMBPerNode()
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
int	getMaxWaitingQueries()
String	getQueueId()
String	getQueueName()
long	getQueueTotalMemoryInMB(int numClusterNodes) Given number of available nodes in the cluster what is the total memory resource share of this queue cluster wide
int	getWaitTimeoutInMs()
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.

Method Detail

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