@InterfaceAudience.Public @InterfaceStability.Evolving public class BufferedMutatorParams extends Object
BufferedMutator
.Constructor and Description |
---|
BufferedMutatorParams(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
BufferedMutator.ExceptionListener |
getListener() |
int |
getMaxKeyValueSize() |
ExecutorService |
getPool() |
TableName |
getTableName() |
long |
getWriteBufferSize() |
BufferedMutatorParams |
listener(BufferedMutator.ExceptionListener listener)
Override the default error handler.
|
BufferedMutatorParams |
maxKeyValueSize(int maxKeyValueSize)
Override the maximum key-value size specified by the provided
Connection 's
Configuration instance, via the configuration key
hbase.client.keyvalue.maxsize . |
BufferedMutatorParams |
pool(ExecutorService pool)
Override the default executor pool defined by the
hbase.htable.threads.*
configuration values. |
BufferedMutatorParams |
writeBufferSize(long writeBufferSize)
Override the write buffer size specified by the provided
Connection 's
Configuration instance, via the configuration key
hbase.client.write.buffer . |
public BufferedMutatorParams(TableName tableName)
public TableName getTableName()
public long getWriteBufferSize()
public BufferedMutatorParams writeBufferSize(long writeBufferSize)
Connection
's
Configuration
instance, via the configuration key
hbase.client.write.buffer
.public int getMaxKeyValueSize()
public BufferedMutatorParams maxKeyValueSize(int maxKeyValueSize)
Connection
's
Configuration
instance, via the configuration key
hbase.client.keyvalue.maxsize
.public ExecutorService getPool()
public BufferedMutatorParams pool(ExecutorService pool)
hbase.htable.threads.*
configuration values.public BufferedMutator.ExceptionListener getListener()
public BufferedMutatorParams listener(BufferedMutator.ExceptionListener listener)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.