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)
protected boolean	isConnectionException(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.paimon.client.ClientPool.ClientPoolImpl

close, execute, execute, isClosed, poolSize, run, 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

newClient

protected org.apache.hadoop.hive.metastore.IMetaStoreClient newClient()

Specified by:

newClient in class ClientPool.ClientPoolImpl<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 class ClientPool.ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>

isConnectionException

protected boolean isConnectionException(Exception e)

Overrides:

isConnectionException in class ClientPool.ClientPoolImpl<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 class ClientPool.ClientPoolImpl<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>