public class CachedClientPool extends java.lang.Object implements ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
The following key elements are supported and can be specified via CatalogProperties.CLIENT_POOL_CACHE_KEYS
:
ClientPool.Action<R,C,E extends java.lang.Exception>
Modifier and Type | Method and 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) |
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
run
in interface ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
org.apache.thrift.TException
java.lang.InterruptedException
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
run
in interface ClientPool<org.apache.hadoop.hive.metastore.IMetaStoreClient,org.apache.thrift.TException>
org.apache.thrift.TException
java.lang.InterruptedException