public class TimeseriesFlushCallback<Req,Res> extends Object implements TableStoreCallback<Req,Res>
| Modifier and Type | Field and Description |
|---|---|
static AtomicLong |
counter |
| 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 | Method and Description |
|---|---|
void |
failedOnException(Req request,
Exception ex) |
void |
onCompleted(PutTimeseriesDataRequest originRequest,
PutTimeseriesDataResponse result) |
void |
onCompleted(Req request,
Res response)
当用户的异步操作成功,将调用此方法。
|
void |
onFailed(Req request,
Exception ex)
当用户的异步操作出错,将调用此方法。
|
public static AtomicLong counter
public TimeseriesFlushCallback(AsyncTimeseriesClientInterface ots, AtomicInteger count, Semaphore semaphore, TableStoreCallback<TimeseriesTableRow,TimeseriesRowResult> callback, Executor executor, TimeseriesWriterHandleStatistics timeseriesWriterHandleStatistics, TimeseriesBucketConfig timeseriesBucketConfig, Semaphore bucketSemaphore, List<TimeseriesGroup> groupList)
public void onCompleted(PutTimeseriesDataRequest originRequest, PutTimeseriesDataResponse result)
public void onCompleted(Req request, Res response)
TableStoreCallbackonCompleted in interface TableStoreCallback<Req,Res>request - 用户的请求response - 用户请求的结果public void onFailed(Req request, Exception ex)
TableStoreCallbackonFailed in interface TableStoreCallback<Req,Res>request - 用户的请求ex - 请求的返回结果无效、或遇到网络异常,则为ClientException;TableStore服务返回的异常,则为TableStoreException。Copyright © 2024. All Rights Reserved.