public class FlushCallbackFactory extends Object implements CallbackFactory
限定符和类型 | 字段和说明 |
---|---|
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 |
构造器和说明 |
---|
FlushCallbackFactory(AsyncClientInterface ots,
Semaphore callbackSemaphore,
TableStoreCallback<RowChange,RowWriteResult> callback,
Executor executor,
WriterHandleStatistics writerStatistics,
BucketConfig bucketConfig,
Semaphore bucketSemaphore) |
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)
CallbackFactory
newInstance
在接口中 CallbackFactory
Copyright © 2021. All Rights Reserved.