BufferedMutator (Apache HBase 1.1.7 API)

All Superinterfaces:

AutoCloseable, Closeable
```
@InterfaceAudience.Public
@InterfaceStability.Evolving
public interface BufferedMutator
extends Closeable
```
Used to communicate with a single HBase table similar to Table but meant for batched, asynchronous puts. Obtain an instance from a Connection and call close() afterwards. Customizations can be applied to the BufferedMutator via the BufferedMutatorParams.

Exception handling with asynchronously via the BufferedMutator.ExceptionListener. The default implementation is to throw the exception upon receipt. This behavior can be overridden with a custom implementation, provided as a parameter with BufferedMutatorParams.listener(BufferedMutator.ExceptionListener).

Map/Reduce jobs are good use cases for using BufferedMutator. Map/reduce jobs benefit from batching, but have no natural flush point. BufferedMutator receives the puts from the M/R job and will batch puts based on some heuristic, such as the accumulated size of the puts, and submit batches of puts asynchronously so that the M/R logic can continue without interruption.

BufferedMutator can also be used on more exotic circumstances. Map/Reduce batch jobs will have a single BufferedMutator per thread. A single BufferedMutator can also be effectively used in high volume online systems to batch puts, with the caveat that extreme circumstances, such as JVM or machine failure, may cause some data loss.

NOTE: This class replaces the functionality that used to be available via HTableInterface.setAutoFlush(boolean) set to false.

See also the BufferedMutatorExample in the hbase-examples module.

Since:

1.0.0

See Also:
ConnectionFactory, Connection

Nested Class Summary

Nested Classes
Modifier and Type Interface and Description

static interface BufferedMutator.ExceptionListener
Listens for asynchronous exceptions on a BufferedMutator.

Nested Classes
Modifier and Type	Interface and Description
`static interface`	`BufferedMutator.ExceptionListener` Listens for asynchronous exceptions on a `BufferedMutator`.

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`close()` Performs a `flush()` and releases any resources held.
`void`	`flush()` Executes all the buffered, asynchronous `Mutation` operations and waits until they are done.
`org.apache.hadoop.conf.Configuration`	`getConfiguration()` Returns the `Configuration` object used by this instance.
`TableName`	`getName()` Gets the fully qualified table name instance of the table that this BufferedMutator writes to.
`long`	`getWriteBufferSize()` Returns the maximum size in bytes of the write buffer for this HTable.
`void`	`mutate(List<? extends Mutation> mutations)` Send some `Mutation`s to the table.
`void`	`mutate(Mutation mutation)` Sends a `Mutation` to the table.

- Method Detail
  - getName
```
TableName getName()
```
    Gets the fully qualified table name instance of the table that this BufferedMutator writes to.
  - getConfiguration
```
org.apache.hadoop.conf.Configuration getConfiguration()
```
    Returns the Configuration object used by this instance.
    The reference returned is not a copy, so any change made to it will affect this instance.
  - mutate
```
void mutate(Mutation mutation)
            throws IOException
```
    Sends a Mutation to the table. The mutations will be buffered and sent over the wire as part of a batch. Currently only supports Put and Delete mutations.
    
    Parameters:
    mutation - The data to send.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - mutate
```
void mutate(List<? extends Mutation> mutations)
            throws IOException
```
    Send some Mutations to the table. The mutations will be buffered and sent over the wire as part of a batch. There is no guarantee of sending entire content of mutations in a single batch; it will be broken up according to the write buffer capacity.
    
    Parameters:
    mutations - The data to send.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - close
```
void close()
           throws IOException
```
    Performs a flush() and releases any resources held.
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface Closeable
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - flush
```
void flush()
           throws IOException
```
    Executes all the buffered, asynchronous Mutation operations and waits until they are done.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - getWriteBufferSize
```
long getWriteBufferSize()
```
    Returns the maximum size in bytes of the write buffer for this HTable.
    The default value comes from the configuration parameter hbase.client.write.buffer.
    
    Returns:
    The size of the write buffer in bytes.

Interface BufferedMutator

Nested Class Summary

Method Summary

Method Detail

getName

getConfiguration

mutate

mutate

close

flush

getWriteBufferSize