BigtableAsyncBufferedMutator (Cloud Bigtable HBase Client for Java 1.12.0 API)

java.lang.Object
- com.google.cloud.bigtable.hbase2_x.BigtableAsyncBufferedMutator

All Implemented Interfaces:

Closeable, AutoCloseable, AsyncBufferedMutator
```
public class BigtableAsyncBufferedMutator
extends Object
implements AsyncBufferedMutator
```
Bigtable implementation of AsyncBufferedMutator

Author:

spollapally

Constructor Summary

Constructors
Constructor and Description
`BigtableAsyncBufferedMutator(HBaseRequestAdapter adapter, org.apache.hadoop.conf.Configuration configuration, BigtableSession session)` 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()`
`List<CompletableFuture<Void>>`	`mutate(List<? extends Mutation> mutations)`
`CompletableFuture<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.AsyncBufferedMutator
getPeriodicalFlushTimeout

- Constructor Detail
  - BigtableAsyncBufferedMutator
```
public BigtableAsyncBufferedMutator(HBaseRequestAdapter adapter,
                                    org.apache.hadoop.conf.Configuration configuration,
                                    BigtableSession session)
```
    Constructor for BigtableBufferedMutator.
    
    Parameters:
    
    adapter - Converts HBase objects to Bigtable protos
    
    configuration - For Additional configuration. TODO: move this to options
    
    session - a BigtableSession
- Method Detail
  - close
```
public void close()
```
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface AsyncBufferedMutator
  - flush
```
public void flush()
```
    Specified by:
    
    flush in interface AsyncBufferedMutator
  - getConfiguration
```
public org.apache.hadoop.conf.Configuration getConfiguration()
```
    Specified by:
    
    getConfiguration in interface AsyncBufferedMutator
  - getName
```
public TableName getName()
```
    Specified by:
    
    getName in interface AsyncBufferedMutator
  - getWriteBufferSize
```
public long getWriteBufferSize()
```
    Specified by:
    
    getWriteBufferSize in interface AsyncBufferedMutator
  - mutate
```
public List<CompletableFuture<Void>> mutate(List<? extends Mutation> mutations)
```
    Specified by:
    
    mutate in interface AsyncBufferedMutator
  - mutate
```
public CompletableFuture<Void> mutate(Mutation mutation)
```
    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 AsyncBufferedMutator

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.

BigtableAsyncBufferedMutator (Cloud Bigtable HBase Client for Java 1.12.0 API)

Class BigtableAsyncBufferedMutator

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

BigtableAsyncBufferedMutator

Method Detail

close

flush

getConfiguration

getName

getWriteBufferSize

mutate

mutate