org.apache.hadoop.hbase.hbql.impl
Class CompletionQueueExecutor<T>

java.lang.Object
  org.apache.hadoop.hbase.hbql.util.PoolableElement<CompletionQueueExecutor>
      org.apache.hadoop.hbase.hbql.impl.CompletionQueueExecutor<T>

Direct Known Subclasses:

ResultExecutor, ResultScannerExecutor

public abstract class CompletionQueueExecutor<T>
extends PoolableElement<CompletionQueueExecutor>

Constructor Summary

protected

CompletionQueueExecutor(QueryExecutorPoolImpl executorPool, int minThreadCount, int maxThreadCount, long keepAliveSecs, int completionQueueSize)

Method Summary

void	addException(HBqlException exception)
void	close()
int	getRejectionCount()
boolean	isShutdown()
boolean	moreResultsPending()
void	putCompletion()
void	putElement(T val)
void	releaseElement()
void	resetElement()
void	shutdown()
void	submitWorkToSubmitterThread(Runnable job)
void	submitWorkToThreadPool(Runnable job)
CompletionQueue.Element<T>	takeElement()
abstract boolean	threadsReadResults()

Methods inherited from class org.apache.hadoop.hbase.hbql.util.PoolableElement

getElementPool

Methods inherited from class java.lang.Object

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

Constructor Detail

CompletionQueueExecutor

protected CompletionQueueExecutor(QueryExecutorPoolImpl executorPool,
                                  int minThreadCount,
                                  int maxThreadCount,
                                  long keepAliveSecs,
                                  int completionQueueSize)
                           throws HBqlException

Throws:

HBqlException

Method Detail

threadsReadResults

public abstract boolean threadsReadResults()

putElement

public void putElement(T val)
                throws HBqlException

Throws:

HBqlException

putCompletion

public void putCompletion()

takeElement

public CompletionQueue.Element<T> takeElement()
                                       throws HBqlException

Throws:

HBqlException

getRejectionCount

public int getRejectionCount()

addException

public void addException(HBqlException exception)

moreResultsPending

public boolean moreResultsPending()

submitWorkToSubmitterThread

public void submitWorkToSubmitterThread(Runnable job)

submitWorkToThreadPool

public void submitWorkToThreadPool(Runnable job)

resetElement

public void resetElement()

Specified by:

resetElement in class PoolableElement<CompletionQueueExecutor>

close

public void close()

releaseElement

public void releaseElement()

Specified by:

releaseElement in class PoolableElement<CompletionQueueExecutor>

isShutdown

public boolean isShutdown()

shutdown

public void shutdown()