@InterfaceAudience.Public @InterfaceStability.Unstable public class ExponentialClientBackoffPolicy extends Object implements ClientBackoffPolicy
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_MAX_BACKOFF |
private float |
heapOccupancyHighWatermark |
private float |
heapOccupancyLowWatermark |
private static org.apache.commons.logging.Log |
LOG |
static String |
MAX_BACKOFF_KEY |
private long |
maxBackoff |
private static long |
ONE_MINUTE |
BACKOFF_POLICY_CLASS
Constructor and Description |
---|
ExponentialClientBackoffPolicy(org.apache.hadoop.conf.Configuration conf) |
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]
|
private static final org.apache.commons.logging.Log LOG
private static final long ONE_MINUTE
public static final long DEFAULT_MAX_BACKOFF
public static final String MAX_BACKOFF_KEY
private long maxBackoff
private float heapOccupancyLowWatermark
private float heapOccupancyHighWatermark
public ExponentialClientBackoffPolicy(org.apache.hadoop.conf.Configuration conf)
public long getBackoffTime(ServerName serverName, byte[] region, ServerStatistics stats)
getBackoffTime
in interface ClientBackoffPolicy
private static double scale(double valueIn, double baseMin, double baseMax, double limitMin, double limitMax)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.