Package org.apache.hadoop.hbase.client

Class ConnectionConfiguration

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionConfiguration

@Private
public class ConnectionConfiguration
extends Object

Configuration parameters for the connection. Configuration is a heavy weight registry that does a lot of string operations and regex matching. Method calls into Configuration account for high CPU usage and have huge performance impact. This class caches connection-related configuration values in the ConnectionConfiguration object so that expensive conf.getXXX() calls are avoided every time HTable, etc is instantiated. see HBASE-12128

Field Summary

Fields

Modifier and Type	Field	Description
private final boolean	clientScannerAsyncPrefetch
static final String	HBASE_CLIENT_META_READ_RPC_TIMEOUT_KEY
static final String	HBASE_CLIENT_META_SCANNER_TIMEOUT
static final String	LOG_SCANNER_ACTIVITY
static final int	MAX_KEYVALUE_SIZE_DEFAULT
static final String	MAX_KEYVALUE_SIZE_KEY
private final int	maxKeyValueSize
private final int	metaOperationTimeout
private final int	metaReadRpcTimeout
private final int	metaReplicaCallTimeoutMicroSecondScan
private final int	operationTimeout
static final String	PRIMARY_CALL_TIMEOUT_MICROSECOND
static final int	PRIMARY_CALL_TIMEOUT_MICROSECOND_DEFAULT
static final String	PRIMARY_SCAN_TIMEOUT_MICROSECOND
static final int	PRIMARY_SCAN_TIMEOUT_MICROSECOND_DEFAULT
private final int	primaryCallTimeoutMicroSecond
private final int	readRpcTimeout
private final int	replicaCallTimeoutMicroSecondScan
private final int	retries
private final int	rpcTimeout
private final int	scannerCaching
private final long	scannerMaxResultSize
static final String	WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS
static final long	WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS_DEFAULT
static final String	WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS
static final long	WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS_DEFAULT
static final long	WRITE_BUFFER_SIZE_DEFAULT
static final String	WRITE_BUFFER_SIZE_KEY
private final long	writeBufferPeriodicFlushTimeoutMs
private final long	writeBufferPeriodicFlushTimerTickMs
private final long	writeBufferSize
private final int	writeRpcTimeout

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConnectionConfiguration()	Constructor This is for internal testing purpose (using the default value).
(package private)	ConnectionConfiguration(org.apache.hadoop.conf.Configuration conf)	Constructor

Method Summary

Modifier and Type	Method	Description
int	getMaxKeyValueSize()
int	getMetaOperationTimeout()
int	getMetaReadRpcTimeout()
int	getMetaReplicaCallTimeoutMicroSecondScan()
int	getOperationTimeout()
int	getPrimaryCallTimeoutMicroSecond()
int	getReadRpcTimeout()
int	getReplicaCallTimeoutMicroSecondScan()
int	getRetriesNumber()
int	getRpcTimeout()
int	getScannerCaching()
long	getScannerMaxResultSize()
long	getWriteBufferPeriodicFlushTimeoutMs()
long	getWriteBufferPeriodicFlushTimerTickMs()
long	getWriteBufferSize()
int	getWriteRpcTimeout()
boolean	isClientScannerAsyncPrefetch()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

WRITE_BUFFER_SIZE_KEY

public static final String WRITE_BUFFER_SIZE_KEY

See Also:

• Constant Field Values

WRITE_BUFFER_SIZE_DEFAULT

public static final long WRITE_BUFFER_SIZE_DEFAULT

See Also:

• Constant Field Values

WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS

public static final String WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS

See Also:

• Constant Field Values

WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS

public static final String WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS

See Also:

• Constant Field Values

WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS_DEFAULT

public static final long WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS_DEFAULT

See Also:

• Constant Field Values

WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS_DEFAULT

public static final long WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS_DEFAULT

See Also:

• Constant Field Values

MAX_KEYVALUE_SIZE_KEY

public static final String MAX_KEYVALUE_SIZE_KEY

See Also:

• Constant Field Values

MAX_KEYVALUE_SIZE_DEFAULT

public static final int MAX_KEYVALUE_SIZE_DEFAULT

See Also:

• Constant Field Values

PRIMARY_CALL_TIMEOUT_MICROSECOND

public static final String PRIMARY_CALL_TIMEOUT_MICROSECOND

See Also:

• Constant Field Values

PRIMARY_CALL_TIMEOUT_MICROSECOND_DEFAULT

public static final int PRIMARY_CALL_TIMEOUT_MICROSECOND_DEFAULT

See Also:

• Constant Field Values

PRIMARY_SCAN_TIMEOUT_MICROSECOND

public static final String PRIMARY_SCAN_TIMEOUT_MICROSECOND

See Also:

• Constant Field Values

PRIMARY_SCAN_TIMEOUT_MICROSECOND_DEFAULT

public static final int PRIMARY_SCAN_TIMEOUT_MICROSECOND_DEFAULT

See Also:

• Constant Field Values

LOG_SCANNER_ACTIVITY

public static final String LOG_SCANNER_ACTIVITY

See Also:

• Constant Field Values

HBASE_CLIENT_META_READ_RPC_TIMEOUT_KEY

public static final String HBASE_CLIENT_META_READ_RPC_TIMEOUT_KEY

See Also:

• Constant Field Values

HBASE_CLIENT_META_SCANNER_TIMEOUT

public static final String HBASE_CLIENT_META_SCANNER_TIMEOUT

See Also:

• Constant Field Values

writeBufferSize

private final long writeBufferSize

writeBufferPeriodicFlushTimeoutMs

private final long writeBufferPeriodicFlushTimeoutMs

writeBufferPeriodicFlushTimerTickMs

private final long writeBufferPeriodicFlushTimerTickMs

metaOperationTimeout

private final int metaOperationTimeout

operationTimeout

private final int operationTimeout

scannerCaching

private final int scannerCaching

scannerMaxResultSize

private final long scannerMaxResultSize

primaryCallTimeoutMicroSecond

private final int primaryCallTimeoutMicroSecond

replicaCallTimeoutMicroSecondScan

private final int replicaCallTimeoutMicroSecondScan

metaReplicaCallTimeoutMicroSecondScan

private final int metaReplicaCallTimeoutMicroSecondScan

retries

private final int retries

maxKeyValueSize

private final int maxKeyValueSize

rpcTimeout

private final int rpcTimeout

readRpcTimeout

private final int readRpcTimeout

metaReadRpcTimeout

private final int metaReadRpcTimeout

writeRpcTimeout

private final int writeRpcTimeout

clientScannerAsyncPrefetch

private final boolean clientScannerAsyncPrefetch

Constructor Details

ConnectionConfiguration

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

Constructor

Parameters:

conf - Configuration object

ConnectionConfiguration

protected ConnectionConfiguration()

Constructor This is for internal testing purpose (using the default value). In real usage, we should read the configuration from the Configuration object.

Method Details

getReadRpcTimeout

public int getReadRpcTimeout()

getMetaReadRpcTimeout

public int getMetaReadRpcTimeout()

getWriteRpcTimeout

public int getWriteRpcTimeout()

getWriteBufferSize

public long getWriteBufferSize()

getWriteBufferPeriodicFlushTimeoutMs

public long getWriteBufferPeriodicFlushTimeoutMs()

getWriteBufferPeriodicFlushTimerTickMs

public long getWriteBufferPeriodicFlushTimerTickMs()

getMetaOperationTimeout

public int getMetaOperationTimeout()

getOperationTimeout

public int getOperationTimeout()

getScannerCaching

public int getScannerCaching()

getPrimaryCallTimeoutMicroSecond

public int getPrimaryCallTimeoutMicroSecond()

getReplicaCallTimeoutMicroSecondScan

public int getReplicaCallTimeoutMicroSecondScan()

getMetaReplicaCallTimeoutMicroSecondScan

public int getMetaReplicaCallTimeoutMicroSecondScan()

getRetriesNumber

public int getRetriesNumber()

getMaxKeyValueSize

public int getMaxKeyValueSize()

getScannerMaxResultSize

public long getScannerMaxResultSize()

isClientScannerAsyncPrefetch

public boolean isClientScannerAsyncPrefetch()

getRpcTimeout

public int getRpcTimeout()