public class TimeseriesBatchRequestManager extends TimeseriesBaseRequestManager
allowDuplicatedRowInBatchRequest, bucketSemaphore, callback, callbackFactory, callbackSemaphore, executor, ots, sendingTimeseriesKeys, timeseriesBucketConfig, timeseriesRowWithGroups, timeseriesWriterConfig, timeseriesWriterHandleStatistics, totalRowsCount, totalSize| Constructor and Description |
|---|
TimeseriesBatchRequestManager(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TimeseriesBucketConfig timeseriesBucketConfig,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
| Modifier and Type | Method and Description |
|---|---|
TimeseriesRequestWithGroups |
makeRequest(String tableName) |
void |
sendRequest(TimeseriesRequestWithGroups timeseriesRequestWithGroups) |
appendTimeseriesRow, clear, getTotalRowsCountpublic TimeseriesBatchRequestManager(AsyncTimeseriesClientInterface ots, TimeseriesWriterConfig timeseriesWriterConfig, TimeseriesBucketConfig timeseriesBucketConfig, Executor executor, TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback, Semaphore callbackSemaphore, Semaphore bucketSemaphore)
public TimeseriesRequestWithGroups makeRequest(String tableName)
public void sendRequest(TimeseriesRequestWithGroups timeseriesRequestWithGroups)
Copyright © 2024. All Rights Reserved.