public class HiveClientPool extends ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
ClientPool.Action<R,C,E extends java.lang.Exception>
Constructor and Description |
---|
HiveClientPool(int poolSize,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and 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) |
public HiveClientPool(int poolSize, org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hive.metastore.IMetaStoreClient newClient()
newClient
in class ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
protected org.apache.hadoop.hive.metastore.IMetaStoreClient reconnect(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
reconnect
in class ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
protected boolean isConnectionException(java.lang.Exception e)
isConnectionException
in class ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
protected void close(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
close
in class ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>