org.apache.hadoop.hbase.client.backoff

Class ExponentialClientBackoffPolicy

java.lang.Object

org.apache.hadoop.hbase.client.backoff.ExponentialClientBackoffPolicy

All Implemented Interfaces:

ClientBackoffPolicy

@InterfaceAudience.Public
public class ExponentialClientBackoffPolicy
extends Object
implements ClientBackoffPolicy

Simple exponential backoff policy on for the client that uses a percent^4 times the max backoff to generate the backoff time.

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_MAX_BACKOFF
private float	heapOccupancyHighWatermark
private float	heapOccupancyLowWatermark
private static org.slf4j.Logger	LOG
static String	MAX_BACKOFF_KEY
private long	maxBackoff
private static long	ONE_MINUTE

Fields inherited from interface org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy

BACKOFF_POLICY_CLASS

Constructor Summary

Constructors

Constructor and Description
ExponentialClientBackoffPolicy(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
long	getBackoffTime(ServerName serverName, byte[] region, ServerStatistics stats)
private static double	scale(double valueIn, double baseMin, double baseMax, double limitMin, double limitMax) Scale valueIn in the range [baseMin,baseMax] to the range [limitMin,limitMax]

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

ONE_MINUTE

private static final long ONE_MINUTE

See Also:

Constant Field Values

DEFAULT_MAX_BACKOFF

public static final long DEFAULT_MAX_BACKOFF

See Also:

Constant Field Values

MAX_BACKOFF_KEY

public static final String MAX_BACKOFF_KEY

See Also:

Constant Field Values

maxBackoff

private long maxBackoff

heapOccupancyLowWatermark

private float heapOccupancyLowWatermark

heapOccupancyHighWatermark

private float heapOccupancyHighWatermark

Constructor Detail

ExponentialClientBackoffPolicy

public ExponentialClientBackoffPolicy(org.apache.hadoop.conf.Configuration conf)

Method Detail

getBackoffTime

public long getBackoffTime(ServerName serverName,
                           byte[] region,
                           ServerStatistics stats)

Specified by:

getBackoffTime in interface ClientBackoffPolicy

Returns:

the number of ms to wait on the client based on the

scale

private static double scale(double valueIn,
                            double baseMin,
                            double baseMax,
                            double limitMin,
                            double limitMax)

Scale valueIn in the range [baseMin,baseMax] to the range [limitMin,limitMax]