Package org.apache.iceberg.hive
Class CachedClientPool
- java.lang.Object
-
- org.apache.iceberg.hive.CachedClientPool
-
- All Implemented Interfaces:
ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
public class CachedClientPool extends java.lang.Object implements ClientPool<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>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <R> R
run(ClientPool.Action<R,org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> action)
<R> R
run(ClientPool.Action<R,org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> action, boolean retry)
-
-
-
Method Detail
-
run
public <R> R run(ClientPool.Action<R,org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> action) throws org.apache.thrift.TException, java.lang.InterruptedException
- Specified by:
run
in interfaceClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
- Throws:
org.apache.thrift.TException
java.lang.InterruptedException
-
run
public <R> R run(ClientPool.Action<R,org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException> action, boolean retry) throws org.apache.thrift.TException, java.lang.InterruptedException
- Specified by:
run
in interfaceClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
- Throws:
org.apache.thrift.TException
java.lang.InterruptedException
-
-