| Modifier and Type | Method and Description |
|---|---|
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> |
DefaultTableStoreTimeseriesWriter.getResultCallback() |
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> |
TableStoreTimeseriesWriter.getResultCallback() |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
void |
TableStoreTimeseriesWriter.addTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
Future<TimeseriesWriterResult> |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(TimeseriesTableRow timeseriesTableRow)
写入一条时序表数据
|
Future<TimeseriesWriterResult> |
TableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(TimeseriesTableRow timeseriesTableRow) |
boolean |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowInternal(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
boolean |
DefaultTableStoreTimeseriesWriter.tryAddTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
boolean |
TableStoreTimeseriesWriter.tryAddTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows,
List<TimeseriesTableRow> dirtyTimeseriesTableRows) |
void |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows,
List<TimeseriesTableRow> dirtyTimeseriesTableRows) |
void |
TableStoreTimeseriesWriter.addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows,
List<TimeseriesTableRow> ditryRows) |
void |
TableStoreTimeseriesWriter.addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows,
List<TimeseriesTableRow> ditryRows) |
Future<TimeseriesWriterResult> |
DefaultTableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(List<TimeseriesTableRow> timeseriesTableRows)
批量写入时序表数据
|
Future<TimeseriesWriterResult> |
TableStoreTimeseriesWriter.addTimeseriesRowChangeWithFuture(List<TimeseriesTableRow> timeseriesTableRows) |
void |
DefaultTableStoreTimeseriesWriter.setResultCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback) |
void |
TableStoreTimeseriesWriter.setResultCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback) |
| Constructor and Description |
|---|
DefaultTableStoreTimeseriesWriter(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig config,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor)
时序表writer
|
DefaultTableStoreTimeseriesWriter(String endpoint,
ServiceCredentials credentials,
String instanceName,
TimeseriesWriterConfig config,
ClientConfiguration cc,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
推荐使用的时序表writer
|
DefaultTableStoreTimeseriesWriter(String endpoint,
ServiceCredentials credentials,
String instanceName,
TimeseriesWriterConfig config,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback)
推荐使用的时序表writer
|
| Modifier and Type | Field and Description |
|---|---|
TimeseriesTableRow |
TimeseriesRowEvent.timeseriesTableRow |
| Modifier and Type | Method and Description |
|---|---|
TimeseriesTableRow |
TimeseriesWriterResult.TimeseriesRowChangeStatus.getTimeseriesTableRow() |
| 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 |
|---|---|
void |
TimeseriesBucket.setResultCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback) |
| Constructor and Description |
|---|
TimeseriesRowChangeStatus(boolean succeed,
TimeseriesTableRow timeseriesTableRow,
Exception exception) |
| Constructor and Description |
|---|
TimeseriesBucket(TimeseriesBucketConfig timeseriesBucketConfig,
AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> resultCallback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
Semaphore semaphore) |
| Modifier and Type | Field and Description |
|---|---|
protected TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> |
TimeseriesFlushCallbackFactory.callback |
| 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) |
TimeseriesFlushCallbackFactory(AsyncTimeseriesClientInterface ots,
Semaphore callbackSemaphore,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TimeseriesBucketConfig timeseriesBucketConfig,
Semaphore bucketSemaphore) |
| Modifier and Type | Field and Description |
|---|---|
TimeseriesTableRow |
TimeseriesRowWithGroup.timeseriesTableRow |
| Modifier and Type | Method and Description |
|---|---|
CallbackImpledFuture<TimeseriesTableRow,TimeseriesWriterResult> |
TimeseriesGroup.getFuture() |
| Modifier and Type | Method and Description |
|---|---|
void |
TimeseriesGroup.failedOneRow(TimeseriesTableRow timeseriesTableRow,
Exception exception) |
void |
TimeseriesGroup.succeedOneRow(TimeseriesTableRow timeseriesTableRow) |
| Constructor and Description |
|---|
TimeseriesRowWithGroup(TimeseriesTableRow timeseriesTableRow,
TimeseriesGroup timeseriesGroup) |
| Modifier and Type | Method and Description |
|---|---|
void |
TimeseriesRowEventHandler.setCallback(TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback) |
| Constructor and Description |
|---|
TimeseriesRowEventHandler(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TimeseriesBucketConfig timeseriesBucketConfig,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
Semaphore semaphore) |
| Modifier and Type | Field and Description |
|---|---|
protected TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> |
TimeseriesBaseRequestManager.callback |
| Constructor and Description |
|---|
TimeseriesBaseRequestManager(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TimeseriesBucketConfig timeseriesBucketConfig,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
TimeseriesBatchRequestManager(AsyncTimeseriesClientInterface ots,
TimeseriesWriterConfig timeseriesWriterConfig,
TimeseriesBucketConfig timeseriesBucketConfig,
Executor executor,
TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics,
TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback,
Semaphore callbackSemaphore,
Semaphore bucketSemaphore) |
Copyright © 2024. All Rights Reserved.