BufferedMutatorParams (Apache HBase 2.1.0-cdh6.3.2 API)

java.lang.Object
- org.apache.hadoop.hbase.client.BufferedMutatorParams

All Implemented Interfaces:: Cloneable

@InterfaceAudience.Public
public class BufferedMutatorParams
extends Object
implements Cloneable

Parameters for instantiating a BufferedMutator.

Constructor Summary

Constructors
Constructor and Description

BufferedMutatorParams(TableName tableName)

Constructors
Constructor and Description
`BufferedMutatorParams(TableName tableName)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`BufferedMutatorParams`	`clone()`
`String`	`getImplementationClassName()`
`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`	`opertationTimeout(int operationTimeout)`
`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`.

Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - BufferedMutatorParams
```
public BufferedMutatorParams(TableName tableName)
```
- Method Detail
  - getTableName
```
public TableName getTableName()
```
  - getWriteBufferSize
```
public long getWriteBufferSize()
```
  - rpcTimeout
```
public BufferedMutatorParams rpcTimeout(int rpcTimeout)
```
  - getRpcTimeout
```
public int getRpcTimeout()
```
  - opertationTimeout
```
public BufferedMutatorParams opertationTimeout(int operationTimeout)
```
  - getOperationTimeout
```
public int getOperationTimeout()
```
  - writeBufferSize
```
public 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.
  - getWriteBufferPeriodicFlushTimeoutMs
```
public long getWriteBufferPeriodicFlushTimeoutMs()
```
  - setWriteBufferPeriodicFlushTimeoutMs
```
public BufferedMutatorParams setWriteBufferPeriodicFlushTimeoutMs(long timeoutMs)
```
    Set the max timeout before the buffer is automatically flushed.
  - getWriteBufferPeriodicFlushTimerTickMs
```
public long getWriteBufferPeriodicFlushTimerTickMs()
```
  - setWriteBufferPeriodicFlushTimerTickMs
```
public BufferedMutatorParams setWriteBufferPeriodicFlushTimerTickMs(long timerTickMs)
```
    Set the TimerTick how often the buffer timeout if checked.
  - getMaxKeyValueSize
```
public int getMaxKeyValueSize()
```
  - maxKeyValueSize
```
public 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.
  - getPool
```
public ExecutorService getPool()
```
  - pool
```
public BufferedMutatorParams pool(ExecutorService pool)
```
    Override the default executor pool defined by the hbase.htable.threads.* configuration values.
  - getImplementationClassName
```
public String getImplementationClassName()
```
    Returns:
    
    Name of the class we will use when we construct a BufferedMutator instance or null if default implementation.
  - implementationClassName
```
public BufferedMutatorParams implementationClassName(String implementationClassName)
```
    Specify a BufferedMutator implementation other than the default.
    
    Parameters:
    
    implementationClassName - Name of the BufferedMutator implementation class
  - getListener
```
public BufferedMutator.ExceptionListener getListener()
```
  - listener
```
public BufferedMutatorParams listener(BufferedMutator.ExceptionListener listener)
```
    Override the default error handler. Default handler simply rethrows the exception.
  - clone
```
public BufferedMutatorParams clone()
```
    Overrides:
    
    clone in class Object

Class BufferedMutatorParams

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

BufferedMutatorParams

Method Detail

getTableName

getWriteBufferSize

rpcTimeout

getRpcTimeout

opertationTimeout

getOperationTimeout

writeBufferSize

getWriteBufferPeriodicFlushTimeoutMs

setWriteBufferPeriodicFlushTimeoutMs

getWriteBufferPeriodicFlushTimerTickMs

setWriteBufferPeriodicFlushTimerTickMs

getMaxKeyValueSize

maxKeyValueSize

getPool

pool

getImplementationClassName

implementationClassName

getListener

listener

clone