org.apache.hadoop.hbase.hbql.impl
Class QueryExecutorPoolImpl

java.lang.Object
  org.apache.hadoop.hbase.hbql.impl.ElementPool<CompletionQueueExecutor>
      org.apache.hadoop.hbase.hbql.impl.QueryExecutorPoolImpl

All Implemented Interfaces:

QueryExecutorPool

public class QueryExecutorPoolImpl
extends ElementPool<CompletionQueueExecutor>
implements QueryExecutorPool

Constructor Summary

QueryExecutorPoolImpl(String poolName, int maxExecutorPoolSize, int minThreadCount, int maxThreadCount, long keepAliveSecs, boolean threadsReadResults, int completionQueueSize)

Method Summary

int	getCompletionQueueSize()
long	getKeepAliveSecs()
int	getMaxThreadCount()
int	getMinThreadCount()
boolean	getThreadsReadResults()
protected CompletionQueueExecutor	newElement()
void	shutdown()

Methods inherited from class org.apache.hadoop.hbase.hbql.impl.ElementPool

addElementToPool, getCreatedCount, getElementPool, getMaxPoolSize, getName, getTakenCount, release, take

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.hbql.client.QueryExecutorPool

getCreatedCount, getMaxPoolSize, getName, getTakenCount

Constructor Detail

QueryExecutorPoolImpl

public QueryExecutorPoolImpl(String poolName,
                             int maxExecutorPoolSize,
                             int minThreadCount,
                             int maxThreadCount,
                             long keepAliveSecs,
                             boolean threadsReadResults,
                             int completionQueueSize)

Method Detail

getMinThreadCount

public int getMinThreadCount()

Specified by:

getMinThreadCount in interface QueryExecutorPool

getMaxThreadCount

public int getMaxThreadCount()

Specified by:

getMaxThreadCount in interface QueryExecutorPool

getKeepAliveSecs

public long getKeepAliveSecs()

Specified by:

getKeepAliveSecs in interface QueryExecutorPool

getThreadsReadResults

public boolean getThreadsReadResults()

Specified by:

getThreadsReadResults in interface QueryExecutorPool

getCompletionQueueSize

public int getCompletionQueueSize()

Specified by:

getCompletionQueueSize in interface QueryExecutorPool

newElement

protected CompletionQueueExecutor newElement()
                                      throws HBqlException

Specified by:

newElement in class ElementPool<CompletionQueueExecutor>

Throws:

HBqlException

shutdown

public void shutdown()