Package org.apache.drill.exec.store.hbase

Class HBaseConnectionManager

java.lang.Object
com.google.common.cache.CacheLoader<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection>
org.apache.drill.exec.store.hbase.HBaseConnectionManager
All Implemented Interfaces:
com.google.common.cache.RemovalListener<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection>
public final class HBaseConnectionManager extends com.google.common.cache.CacheLoader<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection> implements com.google.common.cache.RemovalListener<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection>

A singleton class which manages the lifecycle of HBase connections.

One connection per storage plugin instance is maintained.

  • Nested Class Summary

    Nested classes/interfaces inherited from class com.google.common.cache.CacheLoader

    com.google.common.cache.CacheLoader.InvalidCacheLoadException, com.google.common.cache.CacheLoader.UnsupportedLoadingOperationException

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final HBaseConnectionManager
    INSTANCE
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    closeConnection(org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey key)
     
    org.apache.hadoop.hbase.client.Connection
    getConnection(org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey key)
     
    org.apache.hadoop.hbase.client.Connection
    load(org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey key)
     
    void
    onRemoval(com.google.common.cache.RemovalNotification<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection> notification)
     

    Methods inherited from class com.google.common.cache.CacheLoader

    asyncReloading, from, from, loadAll, reload

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Method Details

    • load

      public org.apache.hadoop.hbase.client.Connection load(org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey key) throws Exception
      Specified by:
      load in class com.google.common.cache.CacheLoader<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection>
      Throws:
      Exception

    • onRemoval

      public void onRemoval(com.google.common.cache.RemovalNotification<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection> notification)
      Specified by:
      onRemoval in interface com.google.common.cache.RemovalListener<org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey,org.apache.hadoop.hbase.client.Connection>

    • getConnection

      public org.apache.hadoop.hbase.client.Connection getConnection(org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey key)

    • closeConnection

      public void closeConnection(org.apache.drill.exec.store.hbase.HBaseStoragePlugin.HBaseConnectionKey key)