public abstract class BaseRequestManager extends Object implements RequestManager
限定符和类型 | 字段和说明 |
---|---|
protected boolean |
allowDuplicatedRowInBatchRequest |
protected BucketConfig |
bucketConfig |
protected Semaphore |
bucketSemaphore |
protected TableStoreCallback<RowChange,RowWriteResult> |
callback |
protected CallbackFactory |
callbackFactory |
protected Semaphore |
callbackSemaphore |
protected Executor |
executor |
protected AsyncClientInterface |
ots |
protected List<RowChangeWithGroup> |
rowChangeWithGroups |
protected ConcurrentSkipListSet<PrimaryKey> |
sendingPrimarykeys |
protected int |
totalRowsCount |
protected int |
totalSize |
protected WriterConfig |
writerConfig |
protected WriterHandleStatistics |
writerStatistics |
构造器和说明 |
---|
BaseRequestManager(AsyncClientInterface ots,
WriterConfig writerConfig,
BucketConfig bucketConfig,
Executor executor,
WriterHandleStatistics writerStatistics,
TableStoreCallback<RowChange,RowWriteResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
限定符和类型 | 方法和说明 |
---|---|
boolean |
appendRowChange(RowChangeWithGroup rowChangeWithGroup) |
void |
clear() |
int |
getTotalRowsCount() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
makeRequest, sendRequest
protected AsyncClientInterface ots
protected BucketConfig bucketConfig
protected WriterConfig writerConfig
protected Semaphore callbackSemaphore
protected TableStoreCallback<RowChange,RowWriteResult> callback
protected Executor executor
protected WriterHandleStatistics writerStatistics
protected Semaphore bucketSemaphore
protected CallbackFactory callbackFactory
protected List<RowChangeWithGroup> rowChangeWithGroups
protected int totalSize
protected int totalRowsCount
protected boolean allowDuplicatedRowInBatchRequest
protected ConcurrentSkipListSet<PrimaryKey> sendingPrimarykeys
public BaseRequestManager(AsyncClientInterface ots, WriterConfig writerConfig, BucketConfig bucketConfig, Executor executor, WriterHandleStatistics writerStatistics, TableStoreCallback<RowChange,RowWriteResult> callback, Semaphore callbackSemaphore, Semaphore bucketSemaphore)
public boolean appendRowChange(RowChangeWithGroup rowChangeWithGroup)
appendRowChange
在接口中 RequestManager
public int getTotalRowsCount()
getTotalRowsCount
在接口中 RequestManager
public void clear()
clear
在接口中 RequestManager
Copyright © 2021. All Rights Reserved.