BigtableAsyncTable (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.hbase2_x

Class BigtableAsyncTable

• java.lang.Object
• • com.google.cloud.bigtable.hbase2_x.BigtableAsyncTable

• All Implemented Interfaces:

  AsyncTable<ScanResultConsumer>

  ---

  
  

  public class BigtableAsyncTable
  extends Object
  implements AsyncTable<ScanResultConsumer>

  Bigtable implementation of AsyncTable.

  Author:

  spollapally

• • Nested Class Summary

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

      AsyncTable.CheckAndMutateBuilder, AsyncTable.CoprocessorCallback<R>, AsyncTable.CoprocessorServiceBuilder<S,R>

  • Constructor Summary

    Constructors 

    Constructor and Description
    BigtableAsyncTable(CommonConnection connection, HBaseRequestAdapter hbaseAdapter)

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    CompletableFuture<Result>	append(Append append)
    <T> List<CompletableFuture<T>>	batch(List<? extends Row> actions)
    AsyncTable.CheckAndMutateBuilder	checkAndMutate(byte[] row, byte[] family)
    AsyncTable.CoprocessorServiceBuilder	coprocessorService(Function arg0, ServiceCaller arg1, AsyncTable.CoprocessorCallback arg2)
    CompletableFuture	coprocessorService(Function arg0, ServiceCaller arg1, byte[] arg2)
    CompletableFuture<Void>	delete(Delete delete)
    List<CompletableFuture<Void>>	delete(List<Delete> deletes)
    CompletableFuture<Boolean>	exists(Get get)
    List<CompletableFuture<Boolean>>	exists(List<Get> gets)
    CompletableFuture<Result>	get(Get get)
    List<CompletableFuture<Result>>	get(List<Get> gets)
    protected BatchExecutor	getBatchExecutor()
    org.apache.hadoop.conf.Configuration	getConfiguration()
    TableName	getName()
    long	getOperationTimeout(TimeUnit timeUnit)
    long	getReadRpcTimeout(TimeUnit arg0)
    long	getRpcTimeout(TimeUnit arg0)
    ResultScanner	getScanner(Scan scan)
    long	getScanTimeout(TimeUnit arg0)
    long	getWriteRpcTimeout(TimeUnit arg0)
    CompletableFuture<Result>	increment(Increment increment)
    CompletableFuture<Void>	mutateRow(RowMutations rowMutations)
    List<CompletableFuture<Void>>	put(List<Put> puts)
    CompletableFuture<Void>	put(Put put)
    void	scan(Scan scan, ScanResultConsumer consumer)
    CompletableFuture<List<Result>>	scanAll(Scan scan)

    • 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.AsyncTable

      batchAll, deleteAll, existsAll, getAll, getScanner, getScanner, incrementColumnValue, incrementColumnValue, putAll

• • Constructor Detail

    • BigtableAsyncTable

      public BigtableAsyncTable(CommonConnection connection,
                                HBaseRequestAdapter hbaseAdapter)

  • Method Detail

    • getBatchExecutor

      protected BatchExecutor getBatchExecutor()

    • append

      public CompletableFuture<Result> append(Append append)

      Specified by:

      append in interface AsyncTable<ScanResultConsumer>

    • batch

      public <T> List<CompletableFuture<T>> batch(List<? extends Row> actions)

      Specified by:

      batch in interface AsyncTable<ScanResultConsumer>

    • checkAndMutate

      public AsyncTable.CheckAndMutateBuilder checkAndMutate(byte[] row,
                                                             byte[] family)

      Specified by:

      checkAndMutate in interface AsyncTable<ScanResultConsumer>

    • delete

      public CompletableFuture<Void> delete(Delete delete)

      Specified by:

      delete in interface AsyncTable<ScanResultConsumer>

    • delete

      public List<CompletableFuture<Void>> delete(List<Delete> deletes)

      Specified by:

      delete in interface AsyncTable<ScanResultConsumer>

    • get

      public CompletableFuture<Result> get(Get get)

      Specified by:

      get in interface AsyncTable<ScanResultConsumer>

    • exists

      public CompletableFuture<Boolean> exists(Get get)

      Specified by:

      exists in interface AsyncTable<ScanResultConsumer>

    • get

      public List<CompletableFuture<Result>> get(List<Get> gets)

      Specified by:

      get in interface AsyncTable<ScanResultConsumer>

    • exists

      public List<CompletableFuture<Boolean>> exists(List<Get> gets)

      Specified by:

      exists in interface AsyncTable<ScanResultConsumer>

    • getConfiguration

      public org.apache.hadoop.conf.Configuration getConfiguration()

      Specified by:

      getConfiguration in interface AsyncTable<ScanResultConsumer>

    • getName

      public TableName getName()

      Specified by:

      getName in interface AsyncTable<ScanResultConsumer>

    • getOperationTimeout

      public long getOperationTimeout(TimeUnit timeUnit)

      Specified by:

      getOperationTimeout in interface AsyncTable<ScanResultConsumer>

    • getReadRpcTimeout

      public long getReadRpcTimeout(TimeUnit arg0)

      Specified by:

      getReadRpcTimeout in interface AsyncTable<ScanResultConsumer>

    • getRpcTimeout

      public long getRpcTimeout(TimeUnit arg0)

      Specified by:

      getRpcTimeout in interface AsyncTable<ScanResultConsumer>

    • getScanTimeout

      public long getScanTimeout(TimeUnit arg0)

      Specified by:

      getScanTimeout in interface AsyncTable<ScanResultConsumer>

    • getWriteRpcTimeout

      public long getWriteRpcTimeout(TimeUnit arg0)

      Specified by:

      getWriteRpcTimeout in interface AsyncTable<ScanResultConsumer>

    • increment

      public CompletableFuture<Result> increment(Increment increment)

      Specified by:

      increment in interface AsyncTable<ScanResultConsumer>

    • mutateRow

      public CompletableFuture<Void> mutateRow(RowMutations rowMutations)

      Specified by:

      mutateRow in interface AsyncTable<ScanResultConsumer>

    • put

      public CompletableFuture<Void> put(Put put)

      Specified by:

      put in interface AsyncTable<ScanResultConsumer>

    • put

      public List<CompletableFuture<Void>> put(List<Put> puts)

      Specified by:

      put in interface AsyncTable<ScanResultConsumer>

    • scanAll

      public CompletableFuture<List<Result>> scanAll(Scan scan)

      Specified by:

      scanAll in interface AsyncTable<ScanResultConsumer>

    • getScanner

      public ResultScanner getScanner(Scan scan)

      Specified by:

      getScanner in interface AsyncTable<ScanResultConsumer>

    • scan

      public void scan(Scan scan,
                       ScanResultConsumer consumer)

      Specified by:

      scan in interface AsyncTable<ScanResultConsumer>

    • coprocessorService

      public CompletableFuture coprocessorService(Function arg0,
                                                  ServiceCaller arg1,
                                                  byte[] arg2)

      Specified by:

      coprocessorService in interface AsyncTable<ScanResultConsumer>

    • coprocessorService

      public AsyncTable.CoprocessorServiceBuilder coprocessorService(Function arg0,
                                                                     ServiceCaller arg1,
                                                                     AsyncTable.CoprocessorCallback arg2)

      Specified by:

      coprocessorService in interface AsyncTable<ScanResultConsumer>