public abstract class BaseWriterRetryStrategy extends Object implements RetryStrategy
限定符和类型 | 字段和说明 |
---|---|
protected long |
timeout |
构造器和说明 |
---|
BaseWriterRetryStrategy(long timeout,
TimeUnit unit) |
限定符和类型 | 方法和说明 |
---|---|
abstract RetryStrategy |
clone()
返回一个同类型且尚未重试的RetryStrategy对象。
|
int |
getRetries()
返回当前重试的次数
|
long |
nextPause(String action,
Exception ex)
得到发起第retries次重试前延迟的时间。
|
protected boolean |
shouldRetry(Exception ex)
Writer特殊使用的重试策略,规则为:
1.
|
public BaseWriterRetryStrategy(long timeout, TimeUnit unit)
public abstract RetryStrategy clone()
RetryStrategy
clone
在接口中 RetryStrategy
clone
在类中 Object
public int getRetries()
RetryStrategy
getRetries
在接口中 RetryStrategy
protected boolean shouldRetry(Exception ex)
ex
- 上次访问失败的错误信息、为ClientException或OTSExceptionpublic long nextPause(String action, Exception ex)
RetryStrategy
nextPause
在接口中 RetryStrategy
action
- 操作名,比如"ListTable"、"GetRow"、"PutRow"等ex
- 上次访问失败的错误信息、为ClientException或TableStoreExceptionCopyright © 2021. All Rights Reserved.