org.apache.iceberg.hive

Class HiveClientPool

java.lang.Object

org.apache.iceberg.hive.ClientPool<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,org.apache.thrift.TException>

org.apache.iceberg.hive.HiveClientPool

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class HiveClientPool
extends ClientPool<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,org.apache.thrift.TException>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.iceberg.hive.ClientPool

ClientPool.Action<R,C,E extends java.lang.Exception>

Constructor Summary

Constructors

Constructor and Description
HiveClientPool(int poolSize, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected void	close(org.apache.hadoop.hive.metastore.HiveMetaStoreClient client)
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 org.apache.iceberg.hive.ClientPool

close, run

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 ClientPool<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 ClientPool<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 ClientPool<org.apache.hadoop.hive.metastore.HiveMetaStoreClient,org.apache.thrift.TException>