public abstract class BaseWriterRetryStrategy extends Object implements RetryStrategy
| Modifier and Type | Field and Description |
|---|---|
protected long |
timeout |
| Constructor and Description |
|---|
BaseWriterRetryStrategy(long timeout,
TimeUnit unit) |
| Modifier and Type | Method and Description |
|---|---|
abstract RetryStrategy |
clone()
返回一个同类型且尚未重试的RetryStrategy对象。
|
int |
getRetries()
返回当前重试的次数
|
long |
nextPause(String action,
Exception ex)
得到发起第retries次重试前延迟的时间。SDK会在这一段时间之后发起第retries次重试。
若返回值小于等于0, 表示不重试.
|
protected boolean |
shouldRetry(Exception ex)
Writer特殊使用的重试策略,规则为:
1.
|
public BaseWriterRetryStrategy(long timeout,
TimeUnit unit)
public abstract RetryStrategy clone()
RetryStrategyclone in interface RetryStrategyclone in class Objectpublic int getRetries()
RetryStrategygetRetries in interface RetryStrategyprotected boolean shouldRetry(Exception ex)
ex - 上次访问失败的错误信息、为ClientException或OTSExceptionpublic long nextPause(String action, Exception ex)
RetryStrategynextPause in interface RetryStrategyaction - 操作名,比如"ListTable"、"GetRow"、"PutRow"等ex - 上次访问失败的错误信息、为ClientException或TableStoreExceptionCopyright © 2024. All Rights Reserved.