public class TimeseriesFlushCallbackFactory extends Object implements TimeseriesCallbackFactory
| Modifier and Type | Field and Description |
|---|---|
protected Semaphore |
bucketSemaphore |
protected TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> |
callback |
protected Semaphore |
callbackSemaphore |
protected Executor |
executor |
protected AsyncTimeseriesClientInterface |
ots |
protected TimeseriesBucketConfig |
timeseriesBucketConfig |
protected TimeseriesWriterConfig |
timeseriesWriterConfig |
protected TimeseriesWriterHandleStatistics |
timeseriesWriterHandleStatistics |
| Constructor and Description |
|---|
TimeseriesFlushCallbackFactory(AsyncTimeseriesClientInterface ots,
Semaphore callbackSemaphore,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TimeseriesBucketConfig timeseriesBucketConfig,
Semaphore bucketSemaphore) |
| Modifier and Type | Method and Description |
|---|---|
TableStoreCallback |
newInstance(List<TimeseriesGroup> groupList)
支持批量管理时,传入每行的群组实例
Callback结束请求后主动更新批量统计
|
protected AsyncTimeseriesClientInterface ots
protected TimeseriesBucketConfig timeseriesBucketConfig
protected TimeseriesWriterConfig timeseriesWriterConfig
protected Semaphore callbackSemaphore
protected TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback
protected Executor executor
protected TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics
protected Semaphore bucketSemaphore
public TimeseriesFlushCallbackFactory(AsyncTimeseriesClientInterface ots, Semaphore callbackSemaphore, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback, Executor executor, TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics, TimeseriesBucketConfig timeseriesBucketConfig, Semaphore bucketSemaphore)
public TableStoreCallback newInstance(List<TimeseriesGroup> groupList)
TimeseriesCallbackFactorynewInstance in interface TimeseriesCallbackFactoryCopyright © 2024. All Rights Reserved.