org.apache.paimon.hive.pool

Class HiveClientPool

java.lang.Object

org.apache.paimon.client.ClientPool.ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>

org.apache.paimon.hive.pool.HiveClientPool

All Implemented Interfaces:

Closeable, AutoCloseable, ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>

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

Pool of Hive Metastore clients.

Mostly copied from iceberg.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.client.ClientPool

ClientPool.Action<R,C,E extends Exception>, ClientPool.ClientPoolImpl<C,E extends Exception>, ClientPool.ExecuteAction<C,E extends Exception>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	close(org.apache.hadoop.hive.metastore.IMetaStoreClient client)

Methods inherited from class org.apache.paimon.client.ClientPool.ClientPoolImpl

close, execute, 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,
                      String clientClassName)

Method Detail

close

protected void close(org.apache.hadoop.hive.metastore.IMetaStoreClient client)

Specified by:

close in class ClientPool.ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>