Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
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 |
AsyncConnection.getBufferedMutatorBuilder(TableName tableName,
ExecutorService pool)
Returns an
AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator . |
AsyncBufferedMutatorBuilder |
AsyncBufferedMutatorBuilder.setMaxAttempts(int maxAttempts)
Set the max attempt times for an operation.
|
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 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 |
AsyncBufferedMutatorBuilder.setRetryPause(long pause,
TimeUnit unit)
Set the base pause time for retrying.
|
AsyncBufferedMutatorBuilder |
AsyncBufferedMutatorBuilder.setRpcTimeout(long timeout,
TimeUnit unit)
Set timeout for each rpc request when doing background flush.
|
AsyncBufferedMutatorBuilder |
AsyncBufferedMutatorBuilder.setStartLogErrorsCnt(int startLogErrorsCnt)
Set the number of retries that are allowed before we start to log.
|
default AsyncBufferedMutatorBuilder |
AsyncBufferedMutatorBuilder.setWriteBufferPeriodicFlush(long timeout,
TimeUnit unit)
Set the periodical flush interval.
|
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 . |
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.