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

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

public class ResultExecutor
extends CompletionQueueExecutor<org.apache.hadoop.hbase.client.Result>

Method Summary

static ResultExecutor	newPooledResultExecutor(QueryExecutorPoolImpl executorPool, 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

Method Detail

newPooledResultExecutor

public static ResultExecutor newPooledResultExecutor(QueryExecutorPoolImpl executorPool,
                                                     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.Result>