AsyncConnection (Apache HBase 2.5.0 API)

All Superinterfaces:

AutoCloseable, Closeable
```
@InterfaceAudience.Public
public interface AsyncConnection
extends Closeable
```
The asynchronous version of Connection.

Since:

2.0.0

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`void`	`clearRegionLocationCache()` Clear all the entries in the region location cache, for all the tables.
`default AsyncAdmin`	`getAdmin()` Retrieve an `AsyncAdmin` implementation to administer an HBase cluster.
`default AsyncAdmin`	`getAdmin(ExecutorService pool)` Retrieve an `AsyncAdmin` implementation to administer an HBase cluster.
`AsyncAdminBuilder`	`getAdminBuilder()` Returns an `AsyncAdminBuilder` for creating `AsyncAdmin`.
`AsyncAdminBuilder`	`getAdminBuilder(ExecutorService pool)` Returns an `AsyncAdminBuilder` for creating `AsyncAdmin`.
`default AsyncBufferedMutator`	`getBufferedMutator(TableName tableName)` Retrieve an `AsyncBufferedMutator` for performing client-side buffering of writes.
`default AsyncBufferedMutator`	`getBufferedMutator(TableName tableName, ExecutorService pool)` Retrieve an `AsyncBufferedMutator` for performing client-side buffering of writes.
`AsyncBufferedMutatorBuilder`	`getBufferedMutatorBuilder(TableName tableName)` Returns an `AsyncBufferedMutatorBuilder` for creating `AsyncBufferedMutator`.
`AsyncBufferedMutatorBuilder`	`getBufferedMutatorBuilder(TableName tableName, ExecutorService pool)` Returns an `AsyncBufferedMutatorBuilder` for creating `AsyncBufferedMutator`.
`org.apache.hadoop.conf.Configuration`	`getConfiguration()` Returns the `Configuration` object used by this instance.
`AsyncTableRegionLocator`	`getRegionLocator(TableName tableName)` Retrieve a AsyncRegionLocator implementation to inspect region information on a table.
`default AsyncTable<AdvancedScanResultConsumer>`	`getTable(TableName tableName)` Retrieve an `AsyncTable` implementation for accessing a table.
`default AsyncTable<ScanResultConsumer>`	`getTable(TableName tableName, ExecutorService pool)` Retrieve an `AsyncTable` implementation for accessing a table.
`AsyncTableBuilder<AdvancedScanResultConsumer>`	`getTableBuilder(TableName tableName)` Returns an `AsyncTableBuilder` for creating `AsyncTable`.
`AsyncTableBuilder<ScanResultConsumer>`	`getTableBuilder(TableName tableName, ExecutorService pool)` Returns an `AsyncTableBuilder` for creating `AsyncTable`.
`boolean`	`isClosed()` Returns whether the connection is closed or not.

Methods inherited from interface java.io.Closeable
close

- Method Detail
  - 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.
  - getRegionLocator
```
AsyncTableRegionLocator getRegionLocator(TableName tableName)
```
    Retrieve a AsyncRegionLocator implementation to inspect region information on a table. The returned AsyncRegionLocator is not thread-safe, so a new instance should be created for each using thread. This is a lightweight operation. Pooling or caching of the returned AsyncRegionLocator is neither required nor desired.
    
    Parameters:
    
    tableName - Name of the table who's region is to be examined
    
    Returns:
    
    An AsyncRegionLocator instance
  - clearRegionLocationCache
```
void clearRegionLocationCache()
```
    Clear all the entries in the region location cache, for all the tables.
    If you only want to clear the cache for a specific table, use AsyncTableRegionLocator.clearRegionLocationCache().
    This may cause performance issue so use it with caution.
  - getTable
```
default AsyncTable<AdvancedScanResultConsumer> getTable(TableName tableName)
```
    Retrieve an AsyncTable implementation for accessing a table.
    The returned instance will use default configs. Use getTableBuilder(TableName) if you want to customize some configs.
    This method no longer checks table existence. An exception will be thrown if the table does not exist only when the first operation is attempted.
    The returned CompletableFuture will be finished directly in the rpc framework's callback thread, so typically you should not do any time consuming work inside these methods. And also the observer style scan API will use AdvancedScanResultConsumer which is designed for experts only. Only use it when you know what you are doing.
    
    Parameters:
    
    tableName - the name of the table
    
    Returns:
    
    an AsyncTable to use for interactions with this table
    
    See Also:
    
    getTableBuilder(TableName)
  - getTableBuilder
```
AsyncTableBuilder<AdvancedScanResultConsumer> getTableBuilder(TableName tableName)
```
    Returns an AsyncTableBuilder for creating AsyncTable.
    This method no longer checks table existence. An exception will be thrown if the table does not exist only when the first operation is attempted.
    
    Parameters:
    
    tableName - the name of the table
  - getTable
```
default AsyncTable<ScanResultConsumer> getTable(TableName tableName,
                                                ExecutorService pool)
```
    Retrieve an AsyncTable implementation for accessing a table.
    This method no longer checks table existence. An exception will be thrown if the table does not exist only when the first operation is attempted.
    
    Parameters:
    
    tableName - the name of the table
    
    pool - the thread pool to use for executing callback
    
    Returns:
    
    an AsyncTable to use for interactions with this table
  - getTableBuilder
```
AsyncTableBuilder<ScanResultConsumer> getTableBuilder(TableName tableName,
                                                      ExecutorService pool)
```
    Returns an AsyncTableBuilder for creating AsyncTable.
    This method no longer checks table existence. An exception will be thrown if the table does not exist only when the first operation is attempted.
    
    Parameters:
    
    tableName - the name of the table
    
    pool - the thread pool to use for executing callback
  - getAdmin
```
default AsyncAdmin getAdmin()
```
    Retrieve an AsyncAdmin implementation to administer an HBase cluster.
    The returned instance will use default configs. Use getAdminBuilder() if you want to customize some configs.
    The admin operation's returned CompletableFuture will be finished directly in the rpc framework's callback thread, so typically you should not do any time consuming work inside these methods.
    
    Returns:
    
    an AsyncAdmin instance for cluster administration
  - getAdminBuilder
```
AsyncAdminBuilder getAdminBuilder()
```
    Returns an AsyncAdminBuilder for creating AsyncAdmin.
    The admin operation's returned CompletableFuture will be finished directly in the rpc framework's callback thread, so typically you should not do any time consuming work inside these methods.
  - getAdmin
```
default AsyncAdmin getAdmin(ExecutorService pool)
```
    Retrieve an AsyncAdmin implementation to administer an HBase cluster.
    The returned instance will use default configs. Use getAdminBuilder(ExecutorService) if you want to customize some configs.
    
    Parameters:
    
    pool - the thread pool to use for executing callback
    
    Returns:
    
    an AsyncAdmin instance for cluster administration
  - getAdminBuilder
```
AsyncAdminBuilder getAdminBuilder(ExecutorService pool)
```
    Returns an AsyncAdminBuilder for creating AsyncAdmin.
    
    Parameters:
    
    pool - the thread pool to use for executing callback
  - getBufferedMutator
```
default AsyncBufferedMutator getBufferedMutator(TableName tableName)
```
    Retrieve an AsyncBufferedMutator for performing client-side buffering of writes.
    The returned instance will use default configs. Use getBufferedMutatorBuilder(TableName) if you want to customize some configs.
    
    Parameters:
    
    tableName - the name of the table
    
    Returns:
    
    an AsyncBufferedMutator for the supplied tableName.
  - getBufferedMutatorBuilder
```
AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName)
```
    Returns an AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator.
    
    Parameters:
    
    tableName - the name of the table
  - getBufferedMutator
```
default AsyncBufferedMutator getBufferedMutator(TableName tableName,
                                                ExecutorService pool)
```
    Retrieve an AsyncBufferedMutator for performing client-side buffering of writes.
    The returned instance will use default configs. Use getBufferedMutatorBuilder(TableName, ExecutorService) if you want to customize some configs.
    
    Parameters:
    
    tableName - the name of the table
    
    pool - the thread pool to use for executing callback
    
    Returns:
    
    an AsyncBufferedMutator for the supplied tableName.
  - getBufferedMutatorBuilder
```
AsyncBufferedMutatorBuilder getBufferedMutatorBuilder(TableName tableName,
                                                      ExecutorService pool)
```
    Returns an AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator.
    
    Parameters:
    
    tableName - the name of the table
    
    pool - the thread pool to use for executing callback
  - isClosed
```
boolean isClosed()
```
    Returns whether the connection is closed or not.
    
    Returns:
    
    true if this connection is closed

Interface AsyncConnection

Method Summary

Methods inherited from interface java.io.Closeable

Method Detail

getConfiguration

getRegionLocator

clearRegionLocationCache

getTable

getTableBuilder

getTable

getTableBuilder

getAdmin

getAdminBuilder

getAdmin

getAdminBuilder

getBufferedMutator

getBufferedMutatorBuilder

getBufferedMutator

getBufferedMutatorBuilder

isClosed