Class HiveClientPool

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, ClientPool<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,​org.apache.thrift.TException>

    public class HiveClientPool
    extends ClientPoolImpl<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,​org.apache.thrift.TException>
    • Nested Class Summary

    • Constructor Summary

      Constructors 
      Constructor Description
      HiveClientPool​(int poolSize, org.apache.hadoop.conf.Configuration conf)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void close​(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client)  
      protected boolean isConnectionException​(java.lang.Exception e)  
      protected org.apache.hadoop.hive.metastore.HiveMetaStoreClient newClient()  
      protected org.apache.hadoop.hive.metastore.HiveMetaStoreClient reconnect​(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • HiveClientPool

        public HiveClientPool​(int poolSize,
                              org.apache.hadoop.conf.Configuration conf)
    • Method Detail

      • newClient

        protected org.apache.hadoop.hive.metastore.HiveMetaStoreClient newClient()
        Specified by:
        newClient in class ClientPoolImpl<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,​org.apache.thrift.TException>
      • reconnect

        protected org.apache.hadoop.hive.metastore.HiveMetaStoreClient reconnect​(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client)
        Specified by:
        reconnect in class ClientPoolImpl<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,​org.apache.thrift.TException>
      • isConnectionException

        protected boolean isConnectionException​(java.lang.Exception e)
        Overrides:
        isConnectionException in class ClientPoolImpl<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,​org.apache.thrift.TException>
      • close

        protected void close​(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client)
        Specified by:
        close in class ClientPoolImpl<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,​org.apache.thrift.TException>