| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.client | 
 Provides HBase Client 
 | 
| Modifier and Type | Class and Description | 
|---|---|
(package private) class  | 
AsyncBufferedMutatorBuilderImpl
The implementation of  
AsyncBufferedMutatorBuilder. | 
| Modifier and Type | Method and Description | 
|---|---|
default AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.disableWriteBufferPeriodicFlush()
Disable the periodical flush, i.e, set the timeout to 0. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncConnection.getBufferedMutatorBuilder(TableName tableName)
Returns an  
AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator. | 
AsyncBufferedMutatorBuilder | 
AsyncConnectionImpl.getBufferedMutatorBuilder(TableName tableName)  | 
AsyncBufferedMutatorBuilder | 
AsyncConnection.getBufferedMutatorBuilder(TableName tableName,
                         ExecutorService pool)
Returns an  
AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator. | 
AsyncBufferedMutatorBuilder | 
AsyncConnectionImpl.getBufferedMutatorBuilder(TableName tableName,
                         ExecutorService pool)  | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setMaxAttempts(int maxAttempts)
Set the max attempt times for an operation. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setMaxAttempts(int maxAttempts)  | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setMaxKeyValueSize(int maxKeyValueSize)
Override the maximum key-value size specified by the provided  
AsyncConnection's
 Configuration instance, via the configuration key
 hbase.client.keyvalue.maxsize. | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setMaxKeyValueSize(int maxKeyValueSize)  | 
default AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setMaxRetries(int maxRetries)
Set the max retry times for an operation. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setOperationTimeout(long timeout,
                   TimeUnit unit)
Set timeout for the background flush operation. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setOperationTimeout(long timeout,
                   TimeUnit unit)  | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setRetryPause(long pause,
             TimeUnit unit)
Set the base pause time for retrying. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setRetryPause(long pause,
             TimeUnit unit)  | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setRpcTimeout(long timeout,
             TimeUnit unit)
Set timeout for each rpc request when doing background flush. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setRpcTimeout(long timeout,
             TimeUnit unit)  | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setStartLogErrorsCnt(int startLogErrorsCnt)
Set the number of retries that are allowed before we start to log. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setStartLogErrorsCnt(int startLogErrorsCnt)  | 
default AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setWriteBufferPeriodicFlush(long timeout,
                           TimeUnit unit)
Set the periodical flush interval. 
 | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setWriteBufferPeriodicFlush(long timeout,
                           TimeUnit unit)  | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilder.setWriteBufferSize(long writeBufferSize)
Override the write buffer size specified by the provided  
AsyncConnection's
 Configuration instance, via the configuration key
 hbase.client.write.buffer. | 
AsyncBufferedMutatorBuilder | 
AsyncBufferedMutatorBuilderImpl.setWriteBufferSize(long writeBufferSize)  | 
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.