public abstract class TimeseriesBaseRequestManager extends Object implements TimeseriesRequestManager
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
allowDuplicatedRowInBatchRequest |
protected Semaphore |
bucketSemaphore |
protected TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> |
callback |
protected TimeseriesCallbackFactory |
callbackFactory |
protected Semaphore |
callbackSemaphore |
protected Executor |
executor |
protected AsyncTimeseriesClientInterface |
ots |
protected ConcurrentSkipListSet<TimeseriesKey> |
sendingTimeseriesKeys |
protected TimeseriesBucketConfig |
timeseriesBucketConfig |
protected List<TimeseriesRowWithGroup> |
timeseriesRowWithGroups |
protected TimeseriesWriterConfig |
timeseriesWriterConfig |
protected TimeseriesWriterHandleStatistics |
timeseriesWriterHandleStatistics |
protected int |
totalRowsCount |
protected int |
totalSize |
| Constructor and Description |
|---|
TimeseriesBaseRequestManager(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TimeseriesBucketConfig timeseriesBucketConfig,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
appendTimeseriesRow(TimeseriesRowWithGroup timeseriesRowWithGroup) |
void |
clear() |
int |
getTotalRowsCount() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitmakeRequest, sendRequestprotected 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
protected TimeseriesCallbackFactory callbackFactory
protected List<TimeseriesRowWithGroup> timeseriesRowWithGroups
protected int totalSize
protected int totalRowsCount
protected boolean allowDuplicatedRowInBatchRequest
protected ConcurrentSkipListSet<TimeseriesKey> sendingTimeseriesKeys
public TimeseriesBaseRequestManager(AsyncTimeseriesClientInterface ots, TimeseriesWriterConfig timeseriesWriterConfig, TimeseriesBucketConfig timeseriesBucketConfig, Executor executor, TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback, Semaphore callbackSemaphore, Semaphore bucketSemaphore)
public boolean appendTimeseriesRow(TimeseriesRowWithGroup timeseriesRowWithGroup)
appendTimeseriesRow in interface TimeseriesRequestManagerpublic int getTotalRowsCount()
getTotalRowsCount in interface TimeseriesRequestManagerpublic void clear()
clear in interface TimeseriesRequestManagerCopyright © 2024. All Rights Reserved.