Uses of Interface
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
-
Uses of AsyncBufferedMutatorBuilder in org.apache.hadoop.hbase.client
Modifier and TypeClassDescription(package private) class
The implementation ofAsyncBufferedMutatorBuilder
.Modifier and TypeMethodDescriptiondefault AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.disableWriteBufferPeriodicFlush()
Disable the periodical flush, i.e, set the timeout to 0.AsyncConnection.getBufferedMutatorBuilder
(TableName tableName) Returns anAsyncBufferedMutatorBuilder
for creatingAsyncBufferedMutator
.AsyncConnection.getBufferedMutatorBuilder
(TableName tableName, ExecutorService pool) Returns anAsyncBufferedMutatorBuilder
for creatingAsyncBufferedMutator
.AsyncConnectionImpl.getBufferedMutatorBuilder
(TableName tableName) AsyncConnectionImpl.getBufferedMutatorBuilder
(TableName tableName, ExecutorService pool) AsyncBufferedMutatorBuilder.setMaxAttempts
(int maxAttempts) Set the max attempt times for an operation.AsyncBufferedMutatorBuilderImpl.setMaxAttempts
(int maxAttempts) AsyncBufferedMutatorBuilder.setMaxKeyValueSize
(int maxKeyValueSize) Override the maximum key-value size specified by the providedAsyncConnection
'sConfiguration
instance, via the configuration keyhbase.client.keyvalue.maxsize
.AsyncBufferedMutatorBuilderImpl.setMaxKeyValueSize
(int maxKeyValueSize) default AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setMaxRetries
(int maxRetries) Set the max retry times for an operation.AsyncBufferedMutatorBuilder.setOperationTimeout
(long timeout, TimeUnit unit) Set timeout for the background flush operation.AsyncBufferedMutatorBuilderImpl.setOperationTimeout
(long timeout, TimeUnit unit) AsyncBufferedMutatorBuilder.setRetryPause
(long pause, TimeUnit unit) Set the base pause time for retrying.AsyncBufferedMutatorBuilderImpl.setRetryPause
(long pause, TimeUnit unit) AsyncBufferedMutatorBuilder.setRpcTimeout
(long timeout, TimeUnit unit) Set timeout for each rpc request when doing background flush.AsyncBufferedMutatorBuilderImpl.setRpcTimeout
(long timeout, TimeUnit unit) AsyncBufferedMutatorBuilder.setStartLogErrorsCnt
(int startLogErrorsCnt) Set the number of retries that are allowed before we start to log.AsyncBufferedMutatorBuilderImpl.setStartLogErrorsCnt
(int startLogErrorsCnt) default AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setWriteBufferPeriodicFlush
(long timeout, TimeUnit unit) Set the periodical flush interval.AsyncBufferedMutatorBuilderImpl.setWriteBufferPeriodicFlush
(long timeout, TimeUnit unit) AsyncBufferedMutatorBuilder.setWriteBufferSize
(long writeBufferSize) Override the write buffer size specified by the providedAsyncConnection
'sConfiguration
instance, via the configuration keyhbase.client.write.buffer
.AsyncBufferedMutatorBuilderImpl.setWriteBufferSize
(long writeBufferSize)