Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AsyncTableBuilderBase<C extends ScanResultConsumerBase>
Base class for all asynchronous table builders.
|
Modifier and Type | Field and Description |
---|---|
private AsyncTableBuilder<?> |
AsyncBufferedMutatorBuilderImpl.tableBuilder |
Modifier and Type | Method and Description |
---|---|
AsyncTableBuilder<AdvancedScanResultConsumer> |
AsyncConnectionImpl.getTableBuilder(TableName tableName) |
AsyncTableBuilder<AdvancedScanResultConsumer> |
AsyncConnection.getTableBuilder(TableName tableName)
Returns an
AsyncTableBuilder for creating AsyncTable . |
AsyncTableBuilder<ScanResultConsumer> |
AsyncConnectionImpl.getTableBuilder(TableName tableName,
ExecutorService pool) |
AsyncTableBuilder<ScanResultConsumer> |
AsyncConnection.getTableBuilder(TableName tableName,
ExecutorService pool)
Returns an
AsyncTableBuilder for creating AsyncTable . |
AsyncTableBuilder<C> |
AsyncTableBuilder.setMaxAttempts(int maxAttempts)
Set the max attempt times for an operation.
|
default AsyncTableBuilder<C> |
AsyncTableBuilder.setMaxRetries(int maxRetries)
Set the max retry times for an operation.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setOperationTimeout(long timeout,
TimeUnit unit)
Set timeout for a whole operation such as get, put or delete.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setReadRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each read(get, scan) rpc request.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setRetryPause(long pause,
TimeUnit unit)
Set the base pause time for retrying.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setRetryPauseForCQTBE(long pause,
TimeUnit unit)
Set the base pause time for retrying when we hit
CallQueueTooBigException . |
AsyncTableBuilder<C> |
AsyncTableBuilder.setRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each rpc request.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setScanTimeout(long timeout,
TimeUnit unit)
As now we have heartbeat support for scan, ideally a scan will never timeout unless the RS is
crash.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setStartLogErrorsCnt(int startLogErrorsCnt)
Set the number of retries that are allowed before we start to log.
|
AsyncTableBuilder<C> |
AsyncTableBuilder.setWriteRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each write(put, delete) rpc request.
|
Constructor and Description |
---|
AsyncBufferedMutatorBuilderImpl(AsyncConnectionConfiguration connConf,
AsyncTableBuilder<?> tableBuilder,
org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer periodicalFlushTimer) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.