@InterfaceAudience.Private class AsyncConnectionConfiguration extends Object
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_START_LOG_ERRORS_AFTER_COUNT |
private int |
maxKeyValueSize |
private int |
maxRetries |
private long |
metaOperationTimeoutNs |
private long |
metaReadRpcTimeoutNs |
private int |
metaScannerCaching |
private long |
metaScanTimeoutNs |
private long |
operationTimeoutNs |
private long |
pauseNs |
private long |
pauseNsForServerOverloaded |
private long |
primaryCallTimeoutNs |
private long |
primaryMetaScanTimeoutNs |
private long |
primaryScanTimeoutNs |
private long |
readRpcTimeoutNs |
private long |
rpcTimeoutNs |
private int |
scannerCaching |
private long |
scannerMaxResultSize |
private long |
scanTimeoutNs |
static String |
START_LOG_ERRORS_AFTER_COUNT_KEY
Configure the number of failures after which the client will start logging.
|
private int |
startLogErrorsCnt
How many retries are allowed before we start to log
|
private long |
writeBufferPeriodicFlushTimeoutNs |
private long |
writeBufferSize |
private long |
writeRpcTimeoutNs |
Constructor and Description |
---|
AsyncConnectionConfiguration(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and 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() |
public static final String START_LOG_ERRORS_AFTER_COUNT_KEY
public static final int DEFAULT_START_LOG_ERRORS_AFTER_COUNT
private final long metaOperationTimeoutNs
private final long operationTimeoutNs
private final long rpcTimeoutNs
private final long readRpcTimeoutNs
private final long metaReadRpcTimeoutNs
private final long writeRpcTimeoutNs
private final long pauseNs
private final long pauseNsForServerOverloaded
private final int maxRetries
private final int startLogErrorsCnt
private final long scanTimeoutNs
private final long metaScanTimeoutNs
private final int scannerCaching
private final int metaScannerCaching
private final long scannerMaxResultSize
private final long writeBufferSize
private final long writeBufferPeriodicFlushTimeoutNs
private final long primaryCallTimeoutNs
private final long primaryScanTimeoutNs
private final long primaryMetaScanTimeoutNs
private final int maxKeyValueSize
AsyncConnectionConfiguration(org.apache.hadoop.conf.Configuration conf)
long getMetaOperationTimeoutNs()
long getOperationTimeoutNs()
long getRpcTimeoutNs()
long getReadRpcTimeoutNs()
long getMetaReadRpcTimeoutNs()
long getWriteRpcTimeoutNs()
long getPauseNs()
long getPauseNsForServerOverloaded()
int getMaxRetries()
int getStartLogErrorsCnt()
long getScanTimeoutNs()
long getMetaScanTimeoutNs()
int getScannerCaching()
int getMetaScannerCaching()
long getScannerMaxResultSize()
long getWriteBufferSize()
long getWriteBufferPeriodicFlushTimeoutNs()
long getPrimaryCallTimeoutNs()
long getPrimaryScanTimeoutNs()
long getPrimaryMetaScanTimeoutNs()
int getMaxKeyValueSize()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.