org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer>
AsyncConnection.getTableBuilder(org.apache.hadoop.hbase.TableName tableName)
Returns an AsyncTableBuilder
for creating AsyncTable
.
org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.ScanResultConsumer>
AsyncConnection.getTableBuilder(org.apache.hadoop.hbase.TableName tableName,
ExecutorService pool)
Returns an AsyncTableBuilder
for creating AsyncTable
.
org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.AdvancedScanResultConsumer>
AsyncConnectionImpl.getTableBuilder(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.AsyncTableBuilder<org.apache.hadoop.hbase.client.ScanResultConsumer>
AsyncConnectionImpl.getTableBuilder(org.apache.hadoop.hbase.TableName tableName,
ExecutorService pool)
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setMaxAttempts(int maxAttempts)
Set the max attempt times for an operation.
default org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setMaxRetries(int maxRetries)
Set the max retry times for an operation.
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setOperationTimeout(long timeout,
TimeUnit unit)
Set timeout for a whole operation such as get, put or delete.
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setReadRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each read(get, scan) rpc request.
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setRequestAttribute(String key,
byte[] value)
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setRetryPause(long pause,
TimeUnit unit)
Set the base pause time for retrying.
default org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setRetryPauseForCQTBE(long pause,
TimeUnit unit)
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setRetryPauseForServerOverloaded(long pause,
TimeUnit unit)
Set the base pause time for retrying when HBaseServerException.isServerOverloaded()
.
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each rpc request.
org.apache.hadoop.hbase.client.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.
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setStartLogErrorsCnt(int startLogErrorsCnt)
Set the number of retries that are allowed before we start to log.
org.apache.hadoop.hbase.client.AsyncTableBuilder<C>
AsyncTableBuilder.setWriteRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each write(put, delete) rpc request.