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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

Throws:

org.apache.thrift.TException

java.lang.InterruptedException