Package org.apache.hadoop.hbase.client

Class AsyncConnectionConfiguration

java.lang.Object

org.apache.hadoop.hbase.client.AsyncConnectionConfiguration

@Private
class AsyncConnectionConfiguration
extends Object

Timeout configs.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_START_LOG_ERRORS_AFTER_COUNT
static final String	HBASE_CLIENT_PAUSE_FOR_SERVER_OVERLOADED	Parameter name for client pause when server is overloaded, denoted by HBaseServerException.isServerOverloaded()
private static final org.slf4j.Logger	LOG
private final int	maxKeyValueSize
private final int	maxRetries
private final long	metaOperationTimeoutNs
private final long	metaReadRpcTimeoutNs
private final int	metaScannerCaching
private final long	metaScanTimeoutNs
private final long	operationTimeoutNs
private final long	pauseNs
private final long	pauseNsForServerOverloaded
private final long	primaryCallTimeoutNs
private final long	primaryMetaScanTimeoutNs
private final long	primaryScanTimeoutNs
private final long	readRpcTimeoutNs
private final long	rpcTimeoutNs
private final int	scannerCaching
private final long	scannerMaxResultSize
private final long	scanTimeoutNs
static final String	START_LOG_ERRORS_AFTER_COUNT_KEY	Configure the number of failures after which the client will start logging.
private final int	startLogErrorsCnt	How many retries are allowed before we start to log
private final long	writeBufferPeriodicFlushTimeoutNs
private final long	writeBufferSize
private final long	writeRpcTimeoutNs

Constructor Summary

Constructors

Constructor	Description
AsyncConnectionConfiguration(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
(package private) int	getMaxKeyValueSize()
(package private) int	getMaxRetries()
(package private) long	getMetaOperationTimeoutNs()
(package private) long	getMetaReadRpcTimeoutNs()
(package private) int	getMetaScannerCaching()
(package private) long	getMetaScanTimeoutNs()
(package private) long	getOperationTimeoutNs()
(package private) long	getPauseNs()
(package private) long	getPauseNsForServerOverloaded()
(package private) long	getPrimaryCallTimeoutNs()
(package private) long	getPrimaryMetaScanTimeoutNs()
(package private) long	getPrimaryScanTimeoutNs()
(package private) long	getReadRpcTimeoutNs()
(package private) long	getRpcTimeoutNs()
(package private) int	getScannerCaching()
(package private) long	getScannerMaxResultSize()
(package private) long	getScanTimeoutNs()
(package private) int	getStartLogErrorsCnt()
(package private) long	getWriteBufferPeriodicFlushTimeoutNs()
(package private) long	getWriteBufferSize()
(package private) long	getWriteRpcTimeoutNs()

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

HBASE_CLIENT_PAUSE_FOR_SERVER_OVERLOADED

public static final String HBASE_CLIENT_PAUSE_FOR_SERVER_OVERLOADED

Parameter name for client pause when server is overloaded, denoted by HBaseServerException.isServerOverloaded()

See Also:

• Constant Field Values

START_LOG_ERRORS_AFTER_COUNT_KEY

public static final String START_LOG_ERRORS_AFTER_COUNT_KEY

Configure the number of failures after which the client will start logging. A few failures is fine: region moved, then is not opened, then is overloaded. We try to have an acceptable heuristic for the number of errors we don't log. 5 was chosen because we wait for 1s at this stage.

See Also:

• Constant Field Values

DEFAULT_START_LOG_ERRORS_AFTER_COUNT

public static final int DEFAULT_START_LOG_ERRORS_AFTER_COUNT

See Also:

• Constant Field Values

metaOperationTimeoutNs

private final long metaOperationTimeoutNs

operationTimeoutNs

private final long operationTimeoutNs

rpcTimeoutNs

private final long rpcTimeoutNs

readRpcTimeoutNs

private final long readRpcTimeoutNs

metaReadRpcTimeoutNs

private final long metaReadRpcTimeoutNs

writeRpcTimeoutNs

private final long writeRpcTimeoutNs

pauseNs

private final long pauseNs

pauseNsForServerOverloaded

private final long pauseNsForServerOverloaded

maxRetries

private final int maxRetries

startLogErrorsCnt

private final int startLogErrorsCnt

How many retries are allowed before we start to log

scanTimeoutNs

private final long scanTimeoutNs

metaScanTimeoutNs

private final long metaScanTimeoutNs

scannerCaching

private final int scannerCaching

metaScannerCaching

private final int metaScannerCaching

scannerMaxResultSize

private final long scannerMaxResultSize

writeBufferSize

private final long writeBufferSize

writeBufferPeriodicFlushTimeoutNs

private final long writeBufferPeriodicFlushTimeoutNs

primaryCallTimeoutNs

private final long primaryCallTimeoutNs

primaryScanTimeoutNs

private final long primaryScanTimeoutNs

primaryMetaScanTimeoutNs

private final long primaryMetaScanTimeoutNs

maxKeyValueSize

private final int maxKeyValueSize

Constructor Details

AsyncConnectionConfiguration

AsyncConnectionConfiguration(org.apache.hadoop.conf.Configuration conf)

Method Details

getMetaOperationTimeoutNs

long getMetaOperationTimeoutNs()

getOperationTimeoutNs

long getOperationTimeoutNs()

getRpcTimeoutNs

long getRpcTimeoutNs()

getReadRpcTimeoutNs

long getReadRpcTimeoutNs()

getMetaReadRpcTimeoutNs

long getMetaReadRpcTimeoutNs()

getWriteRpcTimeoutNs

long getWriteRpcTimeoutNs()

getPauseNs

long getPauseNs()

getPauseNsForServerOverloaded

long getPauseNsForServerOverloaded()

getMaxRetries

int getMaxRetries()

getStartLogErrorsCnt

int getStartLogErrorsCnt()

getScanTimeoutNs

long getScanTimeoutNs()

getMetaScanTimeoutNs

long getMetaScanTimeoutNs()

getScannerCaching

int getScannerCaching()

getMetaScannerCaching

int getMetaScannerCaching()

getScannerMaxResultSize

long getScannerMaxResultSize()

getWriteBufferSize

long getWriteBufferSize()

getWriteBufferPeriodicFlushTimeoutNs

long getWriteBufferPeriodicFlushTimeoutNs()

getPrimaryCallTimeoutNs

long getPrimaryCallTimeoutNs()

getPrimaryScanTimeoutNs

long getPrimaryScanTimeoutNs()

getPrimaryMetaScanTimeoutNs

long getPrimaryMetaScanTimeoutNs()

getMaxKeyValueSize

int getMaxKeyValueSize()