Package org.apache.hadoop.hbase.util

Class RetryCounter

java.lang.Object

org.apache.hadoop.hbase.util.RetryCounter

@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	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	Description
private int	attempts
private static final org.slf4j.Logger	LOG
private RetryCounter.RetryConfig	retryConfig

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

LOG

private static final org.slf4j.Logger LOG

retryConfig

private RetryCounter.RetryConfig retryConfig

attempts

private int attempts

Constructor Details

RetryCounter

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

RetryCounter

public RetryCounter(RetryCounter.RetryConfig retryConfig)

Method Details

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()