alluxio.client.block

Class BlockMasterClientPool

java.lang.Object

alluxio.resource.DynamicResourcePool<BlockMasterClient>

alluxio.client.block.BlockMasterClientPool

All Implemented Interfaces:

Pool<BlockMasterClient>, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class BlockMasterClientPool
extends DynamicResourcePool<BlockMasterClient>

Class for managing block master clients. After obtaining a client with ResourcePool.acquire(), ResourcePool.release(Object) must be called when the thread is done using the client.

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
BlockMasterClientPool(MasterClientContext ctx) Creates a new block master client pool.

Method Summary

Modifier and Type	Method and Description
protected void	closeResource(BlockMasterClient client)
protected BlockMasterClient	createNewResource()
protected com.codahale.metrics.Counter	getMetricCounter()
protected boolean	isHealthy(BlockMasterClient client)
protected boolean	shouldGc(DynamicResourcePool.ResourceInternal<BlockMasterClient> 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

BlockMasterClientPool

public BlockMasterClientPool(MasterClientContext ctx)

Creates a new block master client pool.

Parameters:

ctx - the information required for connecting to Alluxio

Method Detail

closeResource

protected void closeResource(BlockMasterClient client)

Specified by:

closeResource in class DynamicResourcePool<BlockMasterClient>

createNewResource

protected BlockMasterClient createNewResource()

Specified by:

createNewResource in class DynamicResourcePool<BlockMasterClient>

isHealthy

protected boolean isHealthy(BlockMasterClient client)

Specified by:

isHealthy in class DynamicResourcePool<BlockMasterClient>

getMetricCounter

protected com.codahale.metrics.Counter getMetricCounter()

Specified by:

getMetricCounter in class DynamicResourcePool<BlockMasterClient>

shouldGc

protected boolean shouldGc(DynamicResourcePool.ResourceInternal<BlockMasterClient> clientResourceInternal)

Specified by:

shouldGc in class DynamicResourcePool<BlockMasterClient>