alluxio.table.under.hive.util

Class HiveClientPool

java.lang.Object

alluxio.resource.DynamicResourcePool<org.apache.hadoop.hive.metastore.IMetaStoreClient>

alluxio.table.under.hive.util.HiveClientPool

All Implemented Interfaces:

Pool<org.apache.hadoop.hive.metastore.IMetaStoreClient>, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class HiveClientPool
extends DynamicResourcePool<org.apache.hadoop.hive.metastore.IMetaStoreClient>

A pool for hive clients, since hive clients are not thread safe.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.resource.DynamicResourcePool

DynamicResourcePool.Options, DynamicResourcePool.ResourceInternal<R>

Field Summary

Fields inherited from class alluxio.resource.DynamicResourcePool

mClock

Constructor Summary

Constructors

Constructor and Description
HiveClientPool(java.lang.String connectionUri, java.lang.String hiveDbName) Creates a new hive client client pool.

Method Summary

Modifier and Type	Method and Description
CloseableResource<org.apache.hadoop.hive.metastore.IMetaStoreClient>	acquireClientResource()
protected void	closeResource(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
protected org.apache.hadoop.hive.metastore.IMetaStoreClient	createNewResource()
protected boolean	isHealthy(org.apache.hadoop.hive.metastore.IMetaStoreClient client)
protected boolean	shouldGc(DynamicResourcePool.ResourceInternal<org.apache.hadoop.hive.metastore.IMetaStoreClient> clientResourceInternal)

Methods inherited from class alluxio.resource.DynamicResourcePool

acquire, acquire, close, release, size

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveClientPool

public HiveClientPool(java.lang.String connectionUri,
                      java.lang.String hiveDbName)

Creates a new hive client client pool.

Parameters:

connectionUri - the connect uri for the hive metastore

hiveDbName - the db name in hive

Method Detail

closeResource

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

Specified by:

closeResource in class DynamicResourcePool<org.apache.hadoop.hive.metastore.IMetaStoreClient>

createNewResource

protected org.apache.hadoop.hive.metastore.IMetaStoreClient createNewResource()
                                                                       throws java.io.IOException

Specified by:

createNewResource in class DynamicResourcePool<org.apache.hadoop.hive.metastore.IMetaStoreClient>

Throws:

java.io.IOException

isHealthy

protected boolean isHealthy(org.apache.hadoop.hive.metastore.IMetaStoreClient client)

Specified by:

isHealthy in class DynamicResourcePool<org.apache.hadoop.hive.metastore.IMetaStoreClient>

shouldGc

protected boolean shouldGc(DynamicResourcePool.ResourceInternal<org.apache.hadoop.hive.metastore.IMetaStoreClient> clientResourceInternal)

Specified by:

shouldGc in class DynamicResourcePool<org.apache.hadoop.hive.metastore.IMetaStoreClient>

acquireClientResource

public CloseableResource<org.apache.hadoop.hive.metastore.IMetaStoreClient> acquireClientResource()
                                                                                           throws java.io.IOException

Returns:

a closeable resource for the hive client

Throws:

java.io.IOException