public class ReaderRequestManager extends Object
| Constructor and Description |
|---|
ReaderRequestManager(AsyncClientInterface ots,
TableStoreReaderConfig config,
Semaphore callbackSemaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
Semaphore bucketSemaphore,
ReaderStatistics statistics) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
appendPrimaryKey(PkWithGroup pkWithGroup) |
int |
getTotalPksCount() |
ReqWithGroups |
makeRequest() |
void |
sendRequest(ReqWithGroups reqWithGroups) |
void |
setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback) |
void |
setRowQueryCriteria(RowQueryCriteria rowQueryCriteria) |
public ReaderRequestManager(AsyncClientInterface ots, TableStoreReaderConfig config, Semaphore callbackSemaphore, TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback, Executor executor, Semaphore bucketSemaphore, ReaderStatistics statistics)
public int getTotalPksCount()
public ReqWithGroups makeRequest()
public boolean appendPrimaryKey(PkWithGroup pkWithGroup)
public void sendRequest(ReqWithGroups reqWithGroups)
public void setRowQueryCriteria(RowQueryCriteria rowQueryCriteria)
public void setCallback(TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback)
Copyright © 2024. All Rights Reserved.