public class MapRThreadPool extends Object implements com.mapr.fs.jni.MapRCallBackQueue
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CALLBACK_THREADS |
static int |
DEFAULT_WORKER_THREADS |
static int |
MAX_SCAN_THREADS |
static int |
MIN_SCAN_THREADS |
Modifier and Type | Method and Description |
---|---|
void |
addRequest(HBaseRpc dummyRpc,
Scanner scan,
MapRThreadPool mpool) |
void |
addToQ(org.hbase.async.MapRThreadPool.MapRScanPlus mscanPlus) |
void |
closeScanner(com.stumbleupon.async.Deferred<?> d,
com.mapr.fs.MapRHTable mTable,
Scanner scan) |
void |
doFlush(com.stumbleupon.async.Deferred<?> deferred,
com.mapr.fs.MapRHTable mTable) |
boolean |
hasRemainingCapacity() |
void |
runCallbackChain(LinkedList<Object> requests,
LinkedList<Object> responses) |
void |
sendRpc(HBaseRpc rpc,
com.mapr.fs.MapRHTable mTable) |
void |
shutdown() |
org.hbase.async.MapRThreadPool.MapRScanPlus |
takeFromQ() |
public static final int DEFAULT_WORKER_THREADS
public static final int DEFAULT_CALLBACK_THREADS
public static final int MIN_SCAN_THREADS
public static final int MAX_SCAN_THREADS
public boolean hasRemainingCapacity()
public void addToQ(org.hbase.async.MapRThreadPool.MapRScanPlus mscanPlus)
public org.hbase.async.MapRThreadPool.MapRScanPlus takeFromQ()
public void sendRpc(HBaseRpc rpc, com.mapr.fs.MapRHTable mTable)
public void doFlush(com.stumbleupon.async.Deferred<?> deferred, com.mapr.fs.MapRHTable mTable)
public void closeScanner(com.stumbleupon.async.Deferred<?> d, com.mapr.fs.MapRHTable mTable, Scanner scan)
public void runCallbackChain(LinkedList<Object> requests, LinkedList<Object> responses)
runCallbackChain
in interface com.mapr.fs.jni.MapRCallBackQueue
public void shutdown()
public void addRequest(HBaseRpc dummyRpc, Scanner scan, MapRThreadPool mpool)
Copyright ? 2010-2015, The Async HBase Authors