| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowInternal(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
| Modifier and Type | Field and Description |
|---|---|
TimeseriesGroup |
TimeseriesRowEvent.timeseriesGroup |
| Modifier and Type | Method and Description |
|---|---|
boolean |
TimeseriesBucket.addRowChange(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
void |
TimeseriesRowEvent.setValue(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
| Modifier and Type | Method and Description |
|---|---|
TableStoreCallback |
TimeseriesCallbackFactory.newInstance(List<TimeseriesGroup> groupFuture)
支持批量管理时,传入每行的群组实例
Callback结束请求后主动更新批量统计
|
TableStoreCallback |
TimeseriesFlushCallbackFactory.newInstance(List<TimeseriesGroup> groupList) |
| Constructor and Description |
|---|
TimeseriesFlushCallback(AsyncTimeseriesClientInterface ots,
AtomicInteger count,
Semaphore semaphore,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TimeseriesBucketConfig timeseriesBucketConfig,
Semaphore bucketSemaphore,
List<TimeseriesGroup> groupList) |
| Modifier and Type | Field and Description |
|---|---|
TimeseriesGroup |
TimeseriesRowWithGroup.timeseriesGroup |
| Modifier and Type | Method and Description |
|---|---|
List<TimeseriesGroup> |
TimeseriesRequestWithGroups.getGroupList() |
| Constructor and Description |
|---|
TimeseriesRowWithGroup(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
| Constructor and Description |
|---|
TimeseriesRequestWithGroups(Request request,
List<TimeseriesGroup> timeseriesGroupList) |
Copyright © 2024. All Rights Reserved.