org.apache.hadoop.hbase.hbql.client
Class QueryExecutorPoolManager

java.lang.Object
  org.apache.hadoop.hbase.hbql.client.QueryExecutorPoolManager

public class QueryExecutorPoolManager
extends Object

Field Summary

static int	defaultCompletionQueueSize
static long	defaultKeepAliveSecs
static int	defaultMaxExecutorPoolSize
static int	defaultMaxThreadCount
static int	defaultMinThreadCount
static boolean	defaultThreadsReadResults

Constructor Summary

QueryExecutorPoolManager()

Method Summary

static boolean	dropQueryExecutorPool(String name)
static QueryExecutorPool	getQueryExecutorPool(String poolName)
static Set<String>	getQueryExecutorPoolNames()
static QueryExecutorPool	newQueryExecutorPool(String poolName, int maxExecutorPoolSize, int minThreadCount, int maxThreadCount, long keepAliveSecs, boolean threadsReadResults, int completionQueueSize)
static boolean	queryExecutorPoolExists(String name)

Methods inherited from class java.lang.Object

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

Field Detail

defaultMaxExecutorPoolSize

public static int defaultMaxExecutorPoolSize

defaultMinThreadCount

public static int defaultMinThreadCount

defaultMaxThreadCount

public static int defaultMaxThreadCount

defaultKeepAliveSecs

public static long defaultKeepAliveSecs

defaultThreadsReadResults

public static boolean defaultThreadsReadResults

defaultCompletionQueueSize

public static int defaultCompletionQueueSize

Constructor Detail

QueryExecutorPoolManager

public QueryExecutorPoolManager()

Method Detail

newQueryExecutorPool

public static QueryExecutorPool newQueryExecutorPool(String poolName,
                                                     int maxExecutorPoolSize,
                                                     int minThreadCount,
                                                     int maxThreadCount,
                                                     long keepAliveSecs,
                                                     boolean threadsReadResults,
                                                     int completionQueueSize)
                                              throws HBqlException

Throws:

HBqlException

dropQueryExecutorPool

public static boolean dropQueryExecutorPool(String name)

queryExecutorPoolExists

public static boolean queryExecutorPoolExists(String name)

getQueryExecutorPool

public static QueryExecutorPool getQueryExecutorPool(String poolName)
                                              throws HBqlException

Throws:

HBqlException

getQueryExecutorPoolNames

public static Set<String> getQueryExecutorPoolNames()