alluxio.worker.block

Class BlockMasterClientPool

java.lang.Object

alluxio.resource.ResourcePool<BlockMasterClient>

alluxio.worker.block.BlockMasterClientPool

All Implemented Interfaces:

Pool<BlockMasterClient>, Closeable, AutoCloseable

@ThreadSafe
public class BlockMasterClientPool
extends ResourcePool<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.

Field Summary

Fields inherited from class alluxio.resource.ResourcePool

mCurrentCapacity, mMaxCapacity, mResources

Constructor Summary

Constructors

Constructor and Description
BlockMasterClientPool() Creates a new block master client pool.
BlockMasterClientPool(InetSocketAddress address) Creates a new block master client pool.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the resource pool.
BlockMasterClient	createNewResource() Creates a new resource which will be added to the resource pool after the user is done using it.
protected Queue<BlockMasterClient>	getClientList()
protected InetSocketAddress	getMasterAddress()
protected MasterClientContext	getMasterContext()

Methods inherited from class alluxio.resource.ResourcePool

acquire, acquire, release, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.resource.Pool

acquireCloseable, acquireCloseable

Constructor Detail

BlockMasterClientPool

@Inject
public BlockMasterClientPool()

Creates a new block master client pool.

BlockMasterClientPool

public BlockMasterClientPool(@Nullable
                             InetSocketAddress address)

Creates a new block master client pool.

Parameters:

address - the block master address

Method Detail

close

public void close()
           throws IOException

Description copied from class: ResourcePool

Closes the resource pool. After this call, the object should be discarded. Inheriting classes should clean up all their resources here.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class ResourcePool<BlockMasterClient>

Throws:

IOException

createNewResource

public BlockMasterClient createNewResource()

Description copied from class: ResourcePool

Creates a new resource which will be added to the resource pool after the user is done using it. This method should only be called when the capacity of the pool has not been reached. If creating the resource will take a significant amount of time, the inheriting class should avoid calling this method and instead initialize all the resources in the constructor.

Specified by:

createNewResource in class ResourcePool<BlockMasterClient>

Returns:

a resource which will be added to the pool of resources

getMasterAddress

protected InetSocketAddress getMasterAddress()

getMasterContext

protected MasterClientContext getMasterContext()

getClientList

protected Queue<BlockMasterClient> getClientList()