Package org.apache.iceberg.hive
Class HiveClientPool
- java.lang.Object
-
- org.apache.iceberg.ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
-
- org.apache.iceberg.hive.HiveClientPool
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
public class HiveClientPool extends ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.iceberg.ClientPool
ClientPool.Action<R,C,E extends java.lang.Exception>
-
-
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.IMetaStoreClient client)
protected boolean
isConnectionException(java.lang.Exception e)
protected org.apache.hadoop.hive.metastore.IMetaStoreClient
newClient()
protected org.apache.hadoop.hive.metastore.IMetaStoreClient
reconnect(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
-
Methods inherited from class org.apache.iceberg.ClientPoolImpl
close, poolSize, run, run
-
-
-
-
Method Detail
-
newClient
protected org.apache.hadoop.hive.metastore.IMetaStoreClient newClient()
- Specified by:
newClient
in classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
-
reconnect
protected org.apache.hadoop.hive.metastore.IMetaStoreClient reconnect(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
- Specified by:
reconnect
in classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
-
isConnectionException
protected boolean isConnectionException(java.lang.Exception e)
- Overrides:
isConnectionException
in classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
-
close
protected void close(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
- Specified by:
close
in classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
-
-