| 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> | 
AsyncConnection.getTableBuilder(TableName tableName)
Returns an  
AsyncTableBuilder for creating AsyncTable. | 
AsyncTableBuilder<AdvancedScanResultConsumer> | 
AsyncConnectionImpl.getTableBuilder(TableName tableName)  | 
AsyncTableBuilder<ScanResultConsumer> | 
AsyncConnection.getTableBuilder(TableName tableName,
               ExecutorService pool)
Returns an  
AsyncTableBuilder for creating AsyncTable. | 
AsyncTableBuilder<ScanResultConsumer> | 
AsyncConnectionImpl.getTableBuilder(TableName tableName,
               ExecutorService pool)  | 
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.