public class ReaderCallback<Req,Res> extends Object implements TableStoreCallback<Req,Res>
| Modifier and Type | Field and Description |
|---|---|
static AtomicLong |
counter |
| Constructor and Description |
|---|
ReaderCallback(AsyncClientInterface ots,
AtomicInteger count,
Semaphore semaphore,
TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback,
Executor executor,
Semaphore bucketSemaphore,
ReaderStatistics statistics,
Map<String,List<ReaderGroup>> groupMap) |
| Modifier and Type | Method and Description |
|---|---|
void |
failedOnException(Req request,
TableStoreException ex) |
void |
failedOnUnknownException(Req req,
Exception ex) |
void |
onCompleted(Req req,
Res res)
当用户的异步操作成功,将调用此方法。
|
void |
onFailed(Req req,
Exception ex)
当用户的异步操作出错,将调用此方法。
|
public static AtomicLong counter
public ReaderCallback(AsyncClientInterface ots, AtomicInteger count, Semaphore semaphore, TableStoreCallback<PrimaryKeyWithTable,RowReadResult> callback, Executor executor, Semaphore bucketSemaphore, ReaderStatistics statistics, Map<String,List<ReaderGroup>> groupMap)
public void onCompleted(Req req, Res res)
TableStoreCallbackonCompleted in interface TableStoreCallback<Req,Res>req - 用户的请求res - 用户请求的结果public void onFailed(Req req, Exception ex)
TableStoreCallbackonFailed in interface TableStoreCallback<Req,Res>req - 用户的请求ex - 请求的返回结果无效、或遇到网络异常,则为ClientException;TableStore服务返回的异常,则为TableStoreException。public void failedOnException(Req request, TableStoreException ex)
Copyright © 2024. All Rights Reserved.