@InterfaceAudience.Private public class ConnectionConfiguration extends Object
Modifier | Constructor and Description |
---|---|
protected |
ConnectionConfiguration()
Constructor This is for internal testing purpose (using the default value).
|
(package private) |
ConnectionConfiguration(org.apache.hadoop.conf.Configuration conf)
Constructor
|
Modifier and Type | Method and Description |
---|---|
int |
getMaxKeyValueSize() |
int |
getMetaOperationTimeout() |
int |
getMetaReadRpcTimeout() |
int |
getMetaReplicaCallTimeoutMicroSecondScan() |
int |
getMetaScanTimeout() |
int |
getOperationTimeout() |
long |
getPauseMillis() |
long |
getPauseMillisForServerOverloaded() |
int |
getPrimaryCallTimeoutMicroSecond() |
int |
getReadRpcTimeout() |
int |
getReplicaCallTimeoutMicroSecondScan() |
int |
getRetriesNumber() |
int |
getRpcTimeout() |
int |
getScannerCaching() |
long |
getScannerMaxResultSize() |
int |
getScanTimeout() |
long |
getWriteBufferPeriodicFlushTimeoutMs() |
long |
getWriteBufferPeriodicFlushTimerTickMs() |
long |
getWriteBufferSize() |
int |
getWriteRpcTimeout() |
boolean |
isClientScannerAsyncPrefetch() |
private static final org.slf4j.Logger LOG
public static final String WRITE_BUFFER_SIZE_KEY
public static final long WRITE_BUFFER_SIZE_DEFAULT
public static final String WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS
public static final String WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS
public static final long WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS_DEFAULT
public static final long WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS_DEFAULT
public static final String MAX_KEYVALUE_SIZE_KEY
public static final int MAX_KEYVALUE_SIZE_DEFAULT
public static final String PRIMARY_CALL_TIMEOUT_MICROSECOND
public static final int PRIMARY_CALL_TIMEOUT_MICROSECOND_DEFAULT
public static final String PRIMARY_SCAN_TIMEOUT_MICROSECOND
public static final int PRIMARY_SCAN_TIMEOUT_MICROSECOND_DEFAULT
public static final String HBASE_CLIENT_PAUSE_FOR_SERVER_OVERLOADED
HBaseServerException.isServerOverloaded(Throwable)
is true.public static final String HBASE_CLIENT_META_READ_RPC_TIMEOUT_KEY
public static final String HBASE_CLIENT_META_SCANNER_TIMEOUT
private final long writeBufferSize
private final long writeBufferPeriodicFlushTimeoutMs
private final long writeBufferPeriodicFlushTimerTickMs
private final int metaOperationTimeout
private final int operationTimeout
private final int scannerCaching
private final long scannerMaxResultSize
private final int primaryCallTimeoutMicroSecond
private final int replicaCallTimeoutMicroSecondScan
private final int metaReplicaCallTimeoutMicroSecondScan
private final int retries
private final int maxKeyValueSize
private final int rpcTimeout
private final int readRpcTimeout
private final int metaReadRpcTimeout
private final int writeRpcTimeout
private final int scanTimeout
private final int metaScanTimeout
private final boolean clientScannerAsyncPrefetch
private final long pauseMs
private final long pauseMsForServerOverloaded
ConnectionConfiguration(org.apache.hadoop.conf.Configuration conf)
conf
- Configuration objectprotected ConnectionConfiguration()
public int getReadRpcTimeout()
public int getMetaReadRpcTimeout()
public int getWriteRpcTimeout()
public long getWriteBufferSize()
public long getWriteBufferPeriodicFlushTimeoutMs()
public long getWriteBufferPeriodicFlushTimerTickMs()
public int getMetaOperationTimeout()
public int getOperationTimeout()
public int getScannerCaching()
public int getPrimaryCallTimeoutMicroSecond()
public int getReplicaCallTimeoutMicroSecondScan()
public int getMetaReplicaCallTimeoutMicroSecondScan()
public int getRetriesNumber()
public int getMaxKeyValueSize()
public long getScannerMaxResultSize()
public boolean isClientScannerAsyncPrefetch()
public int getRpcTimeout()
public int getScanTimeout()
public int getMetaScanTimeout()
public long getPauseMillis()
public long getPauseMillisForServerOverloaded()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.