public class FlushCallbackFactory extends Object implements CallbackFactory
| Modifier and Type | Field and Description |
|---|---|
protected BucketConfig |
bucketConfig |
protected Semaphore |
bucketSemaphore |
protected TableStoreCallback<RowChange,RowWriteResult> |
callback |
protected Semaphore |
callbackSemaphore |
protected Executor |
executor |
protected AsyncClientInterface |
ots |
protected WriterConfig |
writerConfig |
protected WriterHandleStatistics |
writerStatistics |
| Constructor and Description |
|---|
FlushCallbackFactory(AsyncClientInterface ots,
Semaphore callbackSemaphore,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
WriterHandleStatistics writerStatistics,
BucketConfig bucketConfig,
Semaphore bucketSemaphore) |
| Modifier and Type | Method and Description |
|---|---|
TableStoreCallback |
newInstance(List<Group> groupList)
支持批量管理时,传入每行的群组实例
Callback结束请求后主动更新批量统计
|
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
public FlushCallbackFactory(AsyncClientInterface ots, Semaphore callbackSemaphore, TableStoreCallback<RowChange,RowWriteResult> callback, Executor executor, WriterHandleStatistics writerStatistics, BucketConfig bucketConfig, Semaphore bucketSemaphore)
public TableStoreCallback newInstance(List<Group> groupList)
CallbackFactorynewInstance in interface CallbackFactoryCopyright © 2024. All Rights Reserved.