@InterfaceAudience.Public public class BufferedMutatorParams extends Object implements Cloneable
BufferedMutator
.Modifier and Type | Field and Description |
---|---|
private String |
implementationClassName |
private BufferedMutator.ExceptionListener |
listener |
private int |
maxKeyValueSize |
private int |
operationTimeout |
private ExecutorService |
pool |
private int |
rpcTimeout |
private TableName |
tableName |
(package private) static int |
UNSET |
private long |
writeBufferPeriodicFlushTimeoutMs |
private long |
writeBufferPeriodicFlushTimerTickMs |
private long |
writeBufferSize |
Constructor and Description |
---|
BufferedMutatorParams(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
BufferedMutatorParams |
clone() |
String |
getImplementationClassName()
Returns Name of the class we will use when we construct a
BufferedMutator instance or
null if default implementation. |
BufferedMutator.ExceptionListener |
getListener() |
int |
getMaxKeyValueSize() |
int |
getOperationTimeout() |
ExecutorService |
getPool() |
int |
getRpcTimeout() |
TableName |
getTableName() |
long |
getWriteBufferPeriodicFlushTimeoutMs() |
long |
getWriteBufferPeriodicFlushTimerTickMs() |
long |
getWriteBufferSize() |
BufferedMutatorParams |
implementationClassName(String implementationClassName)
Specify a BufferedMutator implementation other than the default.
|
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 |
operationTimeout(int operationTimeout) |
BufferedMutatorParams |
opertationTimeout(int operationTimeout)
Deprecated.
Since 2.3.0, will be removed in 4.0.0. Use
operationTimeout(int) |
BufferedMutatorParams |
pool(ExecutorService pool)
Override the default executor pool defined by the
hbase.htable.threads.* configuration
values. |
BufferedMutatorParams |
rpcTimeout(int rpcTimeout) |
BufferedMutatorParams |
setWriteBufferPeriodicFlushTimeoutMs(long timeoutMs)
Set the max timeout before the buffer is automatically flushed.
|
BufferedMutatorParams |
setWriteBufferPeriodicFlushTimerTickMs(long timerTickMs)
Set the TimerTick how often the buffer timeout if checked.
|
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 long writeBufferSize
private long writeBufferPeriodicFlushTimeoutMs
private long writeBufferPeriodicFlushTimerTickMs
private int maxKeyValueSize
private ExecutorService pool
private String implementationClassName
private int rpcTimeout
private int operationTimeout
private BufferedMutator.ExceptionListener listener
public BufferedMutatorParams(TableName tableName)
public TableName getTableName()
public long getWriteBufferSize()
public BufferedMutatorParams rpcTimeout(int rpcTimeout)
public int getRpcTimeout()
public BufferedMutatorParams operationTimeout(int operationTimeout)
@Deprecated public BufferedMutatorParams opertationTimeout(int operationTimeout)
operationTimeout(int)
public int getOperationTimeout()
public BufferedMutatorParams writeBufferSize(long writeBufferSize)
Connection
's
Configuration
instance, via the configuration key
hbase.client.write.buffer
.public long getWriteBufferPeriodicFlushTimeoutMs()
public BufferedMutatorParams setWriteBufferPeriodicFlushTimeoutMs(long timeoutMs)
public long getWriteBufferPeriodicFlushTimerTickMs()
public BufferedMutatorParams setWriteBufferPeriodicFlushTimerTickMs(long timerTickMs)
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 String getImplementationClassName()
BufferedMutator
instance or
null if default implementation.public BufferedMutatorParams implementationClassName(String implementationClassName)
implementationClassName
- Name of the BufferedMutator implementation classpublic BufferedMutator.ExceptionListener getListener()
public BufferedMutatorParams listener(BufferedMutator.ExceptionListener listener)
public BufferedMutatorParams clone()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.