ReaderBucket(AsyncClientInterface ots,
Semaphore semaphore,
TableStoreReaderConfig config,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
ReaderStatistics statistics) |
ReaderCallback(AsyncClientInterface ots,
AtomicInteger count,
Semaphore semaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
Semaphore bucketSemaphore,
ReaderStatistics statistics,
Map<String,List<ReaderGroup>> groupMap) |
ReaderCallbackFactory(AsyncClientInterface ots,
Semaphore callbackSemaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
Semaphore bucketSemaphore,
ReaderStatistics statistics) |
ReaderEventHandler(AsyncClientInterface ots,
TableStoreReaderConfig config,
Executor executor,
Semaphore callbackSemaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
ReaderStatistics statistics) |
ReaderRequestManager(AsyncClientInterface ots,
TableStoreReaderConfig config,
Semaphore callbackSemaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
Semaphore bucketSemaphore,
ReaderStatistics statistics) |
ReaderResult(int totalCount,
AtomicReferenceArray<RowReadResult> resultList) |