Package org.apache.hadoop.hbase.client.backoff

Class HBaseServerExceptionPauseManager

java.lang.Object

org.apache.hadoop.hbase.client.backoff.HBaseServerExceptionPauseManager

@Private
public class HBaseServerExceptionPauseManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final long	pauseNs
private final long	pauseNsForServerOverloaded
private final long	timeoutNs

Constructor Summary

Constructors

Constructor	Description
HBaseServerExceptionPauseManager(long pauseNs, long pauseNsForServerOverloaded, long timeoutNs)

Method Summary

Modifier and Type	Method	Description
OptionalLong	getPauseNsFromException(Throwable error, int tries, long startNs)	Returns the nanos, if any, for which the client should wait
long	remainingTimeNs(long startNs)

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

pauseNs

private final long pauseNs

pauseNsForServerOverloaded

private final long pauseNsForServerOverloaded

timeoutNs

private final long timeoutNs

Constructor Details

HBaseServerExceptionPauseManager

public HBaseServerExceptionPauseManager(long pauseNs,
 long pauseNsForServerOverloaded,
 long timeoutNs)

Method Details

getPauseNsFromException

public OptionalLong getPauseNsFromException(Throwable error,
 int tries,
 long startNs)

Returns the nanos, if any, for which the client should wait

Parameters:

error - The exception from the server

tries - The current retry count

Returns:

The time, in nanos, to pause. If empty then pausing would exceed our timeout, so we should throw now

remainingTimeNs

public long remainingTimeNs(long startNs)