default org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.disableWriteBufferPeriodicFlush()
Disable the periodical flush, i.e, set the timeout to 0.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncConnection.getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName)
Returns an AsyncBufferedMutatorBuilder
for creating AsyncBufferedMutator
.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncConnection.getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName,
ExecutorService pool)
Returns an AsyncBufferedMutatorBuilder
for creating AsyncBufferedMutator
.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncConnectionImpl.getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncConnectionImpl.getBufferedMutatorBuilder(org.apache.hadoop.hbase.TableName tableName,
ExecutorService pool)
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setMaxAttempts(int maxAttempts)
Set the max attempt times for an operation.
org.apache.hadoop.hbase.client.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
.
default org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setMaxRetries(int maxRetries)
Set the max retry times for an operation.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setOperationTimeout(long timeout,
TimeUnit unit)
Set timeout for the background flush operation.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setRetryPause(long pause,
TimeUnit unit)
Set the base pause time for retrying.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each rpc request when doing background flush.
org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setStartLogErrorsCnt(int startLogErrorsCnt)
Set the number of retries that are allowed before we start to log.
default org.apache.hadoop.hbase.client.AsyncBufferedMutatorBuilder
AsyncBufferedMutatorBuilder.setWriteBufferPeriodicFlush(long timeout,
TimeUnit unit)
Set the periodical flush interval.
org.apache.hadoop.hbase.client.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
.