BigtableAsyncConnection (Cloud Bigtable HBase Client for Java 1.12.0 API)

org.apache.hadoop.hbase.client

Class BigtableAsyncConnection

• java.lang.Object
• • org.apache.hadoop.hbase.client.BigtableAsyncConnection

• All Implemented Interfaces:

  Closeable, AutoCloseable, AsyncConnection, CommonConnection

  ---

  
  

  public class BigtableAsyncConnection
  extends Object
  implements AsyncConnection, CommonConnection, Closeable

  Bigtable implementation of AsyncConnection

  Author:

  spollapally

• • Constructor Summary

    Constructors 

    Constructor and Description
    BigtableAsyncConnection(org.apache.hadoop.conf.Configuration conf)
    BigtableAsyncConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.AsyncRegistry ignoredRegistry, String ignoredClusterId, User ignoredUser)

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    void	close()
    HBaseRequestAdapter	createAdapter(TableName tableName)
    AsyncAdminBuilder	getAdminBuilder()
    AsyncAdminBuilder	getAdminBuilder(ExecutorService arg0)
    List<HRegionInfo>	getAllRegionInfos(TableName tableName) Retrieve a region information on a table.
    AsyncBufferedMutatorBuilder	getBufferedMutatorBuilder(TableName tableName)
    AsyncBufferedMutatorBuilder	getBufferedMutatorBuilder(TableName tableName, ExecutorService es)
    org.apache.hadoop.conf.Configuration	getConfiguration() Returns the Configuration object used by this instance.
    Set<TableName>	getDisabledTables() Getter for the field disabledTables.
    CompletableFuture<Hbck>	getHbck()
    Hbck	getHbck(ServerName serverName)
    BigtableOptions	getOptions() Getter for the field options.
    AsyncTableRegionLocator	getRegionLocator(TableName tableName)
    BigtableSession	getSession() Get a BigtableSession on which operations can be performed.
    AsyncTableBuilder<AdvancedScanResultConsumer>	getTableBuilder(TableName tableName)
    AsyncTableBuilder<ScanResultConsumer>	getTableBuilder(TableName tableName, ExecutorService ignored)

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

      getAdmin, getAdmin, getBufferedMutator, getBufferedMutator, getTable, getTable

• • Constructor Detail

    • BigtableAsyncConnection

      public BigtableAsyncConnection(org.apache.hadoop.conf.Configuration conf)
                              throws IOException

      Throws:

      IOException

    • BigtableAsyncConnection

      public BigtableAsyncConnection(org.apache.hadoop.conf.Configuration conf,
                                     org.apache.hadoop.hbase.client.AsyncRegistry ignoredRegistry,
                                     String ignoredClusterId,
                                     User ignoredUser)
                              throws IOException

      Throws:

      IOException

  • Method Detail

    • createAdapter

      public HBaseRequestAdapter createAdapter(TableName tableName)

    • getSession

      public BigtableSession getSession()

      Description copied from interface: CommonConnection
      Get a BigtableSession on which operations can be performed.

      Specified by:

      getSession in interface CommonConnection

      Returns:

      a BigtableSession object.

    • getOptions

      public BigtableOptions getOptions()

      Description copied from interface: CommonConnection
      Getter for the field options.

      Specified by:

      getOptions in interface CommonConnection

      Returns:

      a BigtableOptions object.

    • getDisabledTables

      public Set<TableName> getDisabledTables()

      Description copied from interface: CommonConnection
      Getter for the field disabledTables.

      Specified by:

      getDisabledTables in interface CommonConnection

      Returns:

      a Set object that are disabled.

    • close

      public void close()
                 throws IOException

      Specified by:

      close in interface Closeable

      Specified by:

      close in interface AutoCloseable

      Throws:

      IOException

    • getConfiguration

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

      Description copied from interface: CommonConnection
      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.

      Specified by:

      getConfiguration in interface AsyncConnection

      Specified by:

      getConfiguration in interface CommonConnection

      Returns:

      a Configuration object.

    • getAdminBuilder

      public AsyncAdminBuilder getAdminBuilder()

      Specified by:

      getAdminBuilder in interface AsyncConnection

    • getAdminBuilder

      public AsyncAdminBuilder getAdminBuilder(ExecutorService arg0)

      Specified by:

      getAdminBuilder in interface AsyncConnection

    • getBufferedMutatorBuilder

      public AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName)

      Specified by:

      getBufferedMutatorBuilder in interface AsyncConnection

    • getBufferedMutatorBuilder

      public AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName,
                                                                   ExecutorService es)

      Specified by:

      getBufferedMutatorBuilder in interface AsyncConnection

    • getTableBuilder

      public AsyncTableBuilder<AdvancedScanResultConsumer> getTableBuilder(TableName tableName)

      Specified by:

      getTableBuilder in interface AsyncConnection

    • getRegionLocator

      public AsyncTableRegionLocator getRegionLocator(TableName tableName)

      Specified by:

      getRegionLocator in interface AsyncConnection

    • getTableBuilder

      public AsyncTableBuilder<ScanResultConsumer> getTableBuilder(TableName tableName,
                                                                   ExecutorService ignored)

      Specified by:

      getTableBuilder in interface AsyncConnection

    • getAllRegionInfos

      public List<HRegionInfo> getAllRegionInfos(TableName tableName)
                                          throws IOException

      Description copied from interface: CommonConnection
      Retrieve a region information on a table.

      Specified by:

      getAllRegionInfos in interface CommonConnection

      Parameters:

      tableName - Name of the table for which to return region info.

      Returns:

      A List HRegionInfo object

      Throws:

      IOException - if any.

    • getHbck

      public Hbck getHbck(ServerName serverName)

      Specified by:

      getHbck in interface AsyncConnection

    • getHbck

      public CompletableFuture<Hbck> getHbck()

      Specified by:

      getHbck in interface AsyncConnection