org.apache.hadoop.hbase.util

Class RetryCounter

java.lang.Object

org.apache.hadoop.hbase.util.RetryCounter

@InterfaceAudience.Private
public class RetryCounter
extends Object

Operation retry accounting. Use to calculate wait period, getBackoffTimeAndIncrementAttempts()}, or for performing wait, sleepUntilNextRetry(), in accordance with a RetryCounter.RetryConfig, initial settings, and a Retry Policy, (See org.apache.hadoop.io.retry.RetryPolicy). Like guava-retrying.

Since:

0.92.0

See Also:

RetryCounterFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RetryCounter.BackoffPolicy Policy for calculating sleeping intervals between retry attempts
static class	RetryCounter.ExponentialBackoffPolicy
static class	RetryCounter.ExponentialBackoffPolicyWithLimit
static class	RetryCounter.RetryConfig Configuration for a retry counter

Field Summary

Fields

Modifier and Type	Field and Description
private int	attempts
private static org.slf4j.Logger	LOG
private RetryCounter.RetryConfig	retryConfig

Constructor Summary

Constructors

Constructor and Description
RetryCounter(int maxAttempts, long sleepInterval, TimeUnit timeUnit)
RetryCounter(RetryCounter.RetryConfig retryConfig)

Method Summary

Modifier and Type	Method and Description
private static long	addJitter(long interval, float jitter)
int	getAttemptTimes()
long	getBackoffTime()
long	getBackoffTimeAndIncrementAttempts()
int	getMaxAttempts()
boolean	isRetry()
boolean	shouldRetry()
void	sleepUntilNextRetry() Sleep for a back off time as supplied by the backoff policy, and increases the attempts
void	useRetry()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

retryConfig

private RetryCounter.RetryConfig retryConfig

attempts

private int attempts

Constructor Detail

RetryCounter

public RetryCounter(int maxAttempts,
                    long sleepInterval,
                    TimeUnit timeUnit)

RetryCounter

public RetryCounter(RetryCounter.RetryConfig retryConfig)

Method Detail

addJitter

private static long addJitter(long interval,
                              float jitter)

getMaxAttempts

public int getMaxAttempts()

sleepUntilNextRetry

public void sleepUntilNextRetry()
                         throws InterruptedException

Sleep for a back off time as supplied by the backoff policy, and increases the attempts

Throws:

InterruptedException

shouldRetry

public boolean shouldRetry()

useRetry

public void useRetry()

isRetry

public boolean isRetry()

getAttemptTimes

public int getAttemptTimes()

getBackoffTime

public long getBackoffTime()

getBackoffTimeAndIncrementAttempts

public long getBackoffTimeAndIncrementAttempts()