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

java.lang.Object
  org.apache.hadoop.hbase.hbql.util.PoolableElement<CompletionQueueExecutor>
      org.apache.hadoop.hbase.hbql.impl.CompletionQueueExecutor<org.apache.hadoop.hbase.client.ResultScanner>
          org.apache.hadoop.hbase.hbql.impl.ResultScannerExecutor

public class ResultScannerExecutor
extends CompletionQueueExecutor<org.apache.hadoop.hbase.client.ResultScanner>

Constructor Summary

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

Method Summary

static ResultScannerExecutor	newPooledResultScannerExecutor(QueryExecutorPoolImpl executorPool, int minThreadCount, int maxThreadCount, long keepAliveSecs, int completionQueueSize)
static ResultScannerExecutor	newResultScannerExecutor(int minThreadCount, int maxThreadCount, long keepAliveSecs, int completionQueueSize)
boolean	threadsReadResults()

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

addException, close, getRejectionCount, isShutdown, moreResultsPending, putCompletion, putElement, releaseElement, resetElement, shutdown, submitWorkToSubmitterThread, submitWorkToThreadPool, takeElement

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

ResultScannerExecutor

public ResultScannerExecutor(QueryExecutorPoolImpl executorPool,
                             int minThreadCount,
                             int maxThreadCount,
                             long keepAliveSecs,
                             int completionQueueSize)
                      throws HBqlException

Throws:

HBqlException

Method Detail

newPooledResultScannerExecutor

public static ResultScannerExecutor newPooledResultScannerExecutor(QueryExecutorPoolImpl executorPool,
                                                                   int minThreadCount,
                                                                   int maxThreadCount,
                                                                   long keepAliveSecs,
                                                                   int completionQueueSize)
                                                            throws HBqlException

Throws:

HBqlException

newResultScannerExecutor

public static ResultScannerExecutor newResultScannerExecutor(int minThreadCount,
                                                             int maxThreadCount,
                                                             long keepAliveSecs,
                                                             int completionQueueSize)
                                                      throws HBqlException

Throws:

HBqlException

threadsReadResults

public boolean threadsReadResults()

Specified by:

threadsReadResults in class CompletionQueueExecutor<org.apache.hadoop.hbase.client.ResultScanner>