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 voidclose(org.apache.hadoop.hive.metastore.IMetaStoreClient client)protected booleanisConnectionException(java.lang.Exception e)protected org.apache.hadoop.hive.metastore.IMetaStoreClientnewClient()protected org.apache.hadoop.hive.metastore.IMetaStoreClientreconnect(org.apache.hadoop.hive.metastore.IMetaStoreClient client) 
 - 
 
- 
- 
Method Detail
- 
newClient
protected org.apache.hadoop.hive.metastore.IMetaStoreClient newClient()
- Specified by:
 newClientin 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:
 reconnectin classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
 
- 
isConnectionException
protected boolean isConnectionException(java.lang.Exception e)
- Overrides:
 isConnectionExceptionin classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
 
- 
close
protected void close(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
- Specified by:
 closein classClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
 
 - 
 
 -