alluxio.table.under.hive.util

Class DefaultHiveClientPool

java.lang.Object

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

alluxio.table.under.hive.util.AbstractHiveClientPool

alluxio.table.under.hive.util.DefaultHiveClientPool

All Implemented Interfaces:

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

@ThreadSafe
public final class DefaultHiveClientPool
extends AbstractHiveClientPool

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>, DynamicResourcePool.SelectionPolicy

Field Summary

Fields inherited from class alluxio.resource.DynamicResourcePool

mClock, mResources, mSelectionPolicy

Constructor Summary

Constructors

Constructor and Description
DefaultHiveClientPool(String connectionUri) 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) Closes the resource.
protected org.apache.hadoop.hive.metastore.IMetaStoreClient	createNewResource() Creates a new resource.
protected com.codahale.metrics.Counter	getMetricCounter()
protected boolean	isHealthy(org.apache.hadoop.hive.metastore.IMetaStoreClient client) Checks whether a resource is healthy or not.
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

DefaultHiveClientPool

public DefaultHiveClientPool(String connectionUri)

Creates a new hive client client pool.

Parameters:

connectionUri - the connect uri for the hive metastore

Method Detail

closeResource

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

Description copied from class: DynamicResourcePool

Closes the resource. After this, the resource should not be used. It is not guaranteed that the resource is closed after the function returns.

Specified by:

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

Parameters:

client - the resource to close

createNewResource

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

Description copied from class: DynamicResourcePool

Creates a new resource.

Specified by:

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

Returns:

the newly created resource

Throws:

IOException

isHealthy

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

Description copied from class: DynamicResourcePool

Checks whether a resource is healthy or not.

Specified by:

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

Parameters:

client - the resource to check

Returns:

true if the resource is healthy

getMetricCounter

protected com.codahale.metrics.Counter getMetricCounter()

Specified by:

getMetricCounter 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>

Parameters:

clientResourceInternal - the resource to check

Returns:

true if the resource should be garbage collected

acquireClientResource

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

Specified by:

acquireClientResource in class AbstractHiveClientPool

Returns:

a closeable resource for the hive client

Throws:

IOException