@InterfaceAudience.Public @InterfaceStability.Evolving public class BufferedMutatorParams extends Object
BufferedMutator
.Modifier and Type | Field and Description |
---|---|
private BufferedMutator.ExceptionListener |
listener |
private int |
maxKeyValueSize |
private ExecutorService |
pool |
private TableName |
tableName |
(package private) static int |
UNSET |
private long |
writeBufferSize |
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 . |
static final int UNSET
private final TableName tableName
private long writeBufferSize
private int maxKeyValueSize
private ExecutorService pool
private BufferedMutator.ExceptionListener listener
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.