BigtableBufferedMutator (Cloud Bigtable HBase Client for Java 1.12.0 API)

java.lang.Object
- com.google.cloud.bigtable.hbase.BigtableBufferedMutator

All Implemented Interfaces:

Closeable, AutoCloseable, BufferedMutator
```
public class BigtableBufferedMutator
extends Object
implements BufferedMutator
```
Bigtable's BufferedMutator implementation.

Version:

$Id: $Id

Author:

sduskis

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.BufferedMutator
  BufferedMutator.ExceptionListener

Field Summary

Fields
Modifier and Type Field and Description

protected static Logger LOG
- Fields inherited from interface org.apache.hadoop.hbase.client.BufferedMutator
  CLASSNAME_KEY, MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS

Constructor Summary

Constructors
Constructor and Description
`BigtableBufferedMutator(HBaseRequestAdapter adapter, org.apache.hadoop.conf.Configuration configuration, BigtableSession session, BufferedMutator.ExceptionListener listener)` Constructor for BigtableBufferedMutator.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`close()`
`void`	`flush()`
`org.apache.hadoop.conf.Configuration`	`getConfiguration()`
`TableName`	`getName()`
`long`	`getWriteBufferSize()`
`boolean`	`hasInflightRequests()` hasInflightRequests.
`void`	`mutate(List<? extends Mutation> mutations)`
`void`	`mutate(Mutation mutation)`

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

Methods inherited from interface org.apache.hadoop.hbase.client.BufferedMutator
disableWriteBufferPeriodicFlush, getWriteBufferPeriodicFlushTimeoutMs, getWriteBufferPeriodicFlushTimerTickMs, setOperationTimeout, setRpcTimeout, setWriteBufferPeriodicFlush, setWriteBufferPeriodicFlush

- Field Detail
  - LOG
```
protected static final Logger LOG
```
- Constructor Detail
  - BigtableBufferedMutator
```
public BigtableBufferedMutator(HBaseRequestAdapter adapter,
                               org.apache.hadoop.conf.Configuration configuration,
                               BigtableSession session,
                               BufferedMutator.ExceptionListener listener)
```
    Constructor for BigtableBufferedMutator.
    
    Parameters:
    
    adapter - Converts HBase objects to Bigtable protos
    
    configuration - For Additional configuration. TODO: move this to options
    
    listener - Handles exceptions. By default, it just throws the exception.
    
    session - a BigtableSession object.
- Method Detail
  - close
```
public void close()
           throws IOException
```
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface BufferedMutator
    
    Throws:
    
    IOException
  - flush
```
public void flush()
           throws IOException
```
    Specified by:
    
    flush in interface BufferedMutator
    
    Throws:
    
    IOException
  - getConfiguration
```
public org.apache.hadoop.conf.Configuration getConfiguration()
```
    Specified by:
    
    getConfiguration in interface BufferedMutator
  - getName
```
public TableName getName()
```
    Specified by:
    
    getName in interface BufferedMutator
  - getWriteBufferSize
```
public long getWriteBufferSize()
```
    Specified by:
    
    getWriteBufferSize in interface BufferedMutator
  - mutate
```
public void mutate(List<? extends Mutation> mutations)
            throws IOException
```
    Specified by:
    
    mutate in interface BufferedMutator
    
    Throws:
    
    IOException
  - mutate
```
public void mutate(Mutation mutation)
            throws IOException
```
    Being a Mutation. This method will block if either of the following are true: 1) There are more than maxInflightRpcs RPCs in flight 2) There are more than getWriteBufferSize() bytes pending
    
    Specified by:
    
    mutate in interface BufferedMutator
    
    Throws:
    
    IOException
  - hasInflightRequests
```
public boolean hasInflightRequests()
```
    hasInflightRequests.
    
    Returns:
    
    a boolean.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2024-02-15 UTC.

BigtableBufferedMutator (Cloud Bigtable HBase Client for Java 1.12.0 API)

Class BigtableBufferedMutator

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.BufferedMutator

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.client.BufferedMutator

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.hadoop.hbase.client.BufferedMutator

Field Detail

LOG

Constructor Detail

BigtableBufferedMutator

Method Detail

close

flush

getConfiguration

getName

getWriteBufferSize

mutate

mutate

hasInflightRequests