alluxio.client.file

Class FileSystemContext

java.lang.Object

alluxio.client.file.FileSystemContext

All Implemented Interfaces:

Closeable, AutoCloseable

@ThreadSafe
public final class FileSystemContext
extends Object
implements Closeable

An object which houses resources and information for performing FileSystem operations. Typically, a single JVM should only need one instance of a FileSystem to connect to Alluxio. The reference to that client object should be shared among threads. A second FileSystemContext object should only be created when a user needs to connect to Alluxio with a different Subject and/or AlluxioConfiguration. FileSystemContext instances should be created sparingly because each instance creates its own thread pools of FileSystemMasterClient and BlockMasterClient which can lead to inefficient use of client machine resources. A FileSystemContext should be closed once the user is done performing operations with Alluxio and no more connections need to be made. Once a FileSystemContext is closed it is preferred that the user of the class create a new instance with create(alluxio.conf.AlluxioConfiguration) to create a new context, rather than reinitializing using the init(alluxio.ClientContext, alluxio.master.MasterInquireClient) method. NOTE: Each context maintains a pool of file system master clients that is already thread-safe. Synchronizing FileSystemContext methods could lead to deadlock: thread A attempts to acquire a client when there are no clients left in the pool and blocks holding a lock on the FileSystemContext, when thread B attempts to release a client it owns it is unable to do so, because thread A holds the lock on FileSystemContext.

Method Summary

Modifier and Type	Method and Description
alluxio.resource.CloseableResource<BlockMasterClient>	acquireBlockMasterClientResource() Acquires a block master client resource from the block master client pool.
BlockWorkerClient	acquireBlockWorkerClient(alluxio.wire.WorkerNetAddress workerNetAddress) Acquires a block worker client from the client pools.
alluxio.resource.CloseableResource<FileSystemMasterClient>	acquireMasterClientResource() Acquires a file system master client from the file system master client pool.
FileSystemContextReinitializer.ReinitBlockerResource	blockReinit() Acquires the resource to block reinitialization.
void	close() Closes all the resources associated with the context.
static FileSystemContext	create(alluxio.conf.AlluxioConfiguration conf) Creates a FileSystemContext with a null subject.
static FileSystemContext	create(alluxio.ClientContext clientContext)
static FileSystemContext	create(Subject subject, alluxio.conf.AlluxioConfiguration conf)
static FileSystemContext	create(Subject subject, alluxio.master.MasterInquireClient masterInquireClient, alluxio.conf.AlluxioConfiguration alluxioConf) This method is provided for testing, use the create(alluxio.conf.AlluxioConfiguration) methods.
alluxio.ClientContext	getClientContext()
alluxio.conf.AlluxioConfiguration	getClusterConf()
String	getId()
alluxio.wire.WorkerNetAddress	getLocalWorker()
InetSocketAddress	getMasterAddress()
alluxio.master.MasterClientContext	getMasterClientContext()
alluxio.conf.AlluxioConfiguration	getPathConf(alluxio.AlluxioURI path) The path level configuration is a SpecificPathConfiguration.
boolean	hasLocalWorker()
void	reinit(boolean updateClusterConf, boolean updatePathConf) Closes the context, updates configuration from meta master, then re-initializes the context.
void	releaseBlockWorkerClient(alluxio.wire.WorkerNetAddress workerNetAddress, BlockWorkerClient client) Releases a block worker client to the client pools.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static FileSystemContext create(alluxio.conf.AlluxioConfiguration conf)

Creates a FileSystemContext with a null subject.

Parameters:

conf - Alluxio configuration

Returns:

an instance of file system context with no subject associated

create

public static FileSystemContext create(@Nullable
                                       Subject subject,
                                       @Nullable
                                       alluxio.conf.AlluxioConfiguration conf)

Parameters:

subject - the parent subject, set to null if not present

conf - Alluxio configuration

Returns:

a context

create

public static FileSystemContext create(alluxio.ClientContext clientContext)

Parameters:

clientContext - the ClientContext containing the subject and configuration

Returns:

the FileSystemContext

create

public static FileSystemContext create(Subject subject,
                                       alluxio.master.MasterInquireClient masterInquireClient,
                                       alluxio.conf.AlluxioConfiguration alluxioConf)

This method is provided for testing, use the create(alluxio.conf.AlluxioConfiguration) methods. The returned context object will not be cached automatically.

Parameters:

subject - the parent subject, set to null if not present

masterInquireClient - the client to use for determining the master; note that if the context is reset, this client will be replaced with a new masterInquireClient based on the original configuration.

alluxioConf - Alluxio configuration

Returns:

the context

close

public void close()
           throws IOException

Closes all the resources associated with the context. Make sure all the resources are released back to this context before calling this close. After closing the context, all the resources that acquired from this context might fail. Only call this when you are done with using the FileSystem associated with this FileSystemContext.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

blockReinit

public FileSystemContextReinitializer.ReinitBlockerResource blockReinit()

Acquires the resource to block reinitialization. If reinitialization is happening, this method will block until reinitialization succeeds or fails, if it fails, a RuntimeException will be thrown explaining the reinitialization's failure and automatically closes the resource. RuntimeException is thrown because this method is called before requiring resources from the context, if reinitialization fails, the resources might be half closed, to prevent resource leaks, we thrown RuntimeException here to force callers to fail since there is no way to recover.

Returns:

the resource

reinit

public void reinit(boolean updateClusterConf,
                   boolean updatePathConf)
            throws alluxio.exception.status.UnavailableException,
                   IOException

Closes the context, updates configuration from meta master, then re-initializes the context. The reinitializer is not closed, which means the heartbeat thread inside it is not stopped. The reinitializer will be reset with the updated context if reinitialization succeeds, otherwise, the reinitializer is not reset. Blocks until there is no active RPCs.

Parameters:

updateClusterConf - whether cluster level configuration should be updated

updatePathConf - whether path level configuration should be updated

Throws:

alluxio.exception.status.UnavailableException - when failed to load configuration from master

IOException - when failed to close the context

getId

public String getId()

Returns:

the unique ID of this context

getMasterClientContext

public alluxio.master.MasterClientContext getMasterClientContext()

Returns:

the MasterClientContext backing this context

getClientContext

public alluxio.ClientContext getClientContext()

Returns:

the ClientContext backing this FileSystemContext

getClusterConf

public alluxio.conf.AlluxioConfiguration getClusterConf()

Returns:

the cluster level configuration backing this FileSystemContext

getPathConf

public alluxio.conf.AlluxioConfiguration getPathConf(alluxio.AlluxioURI path)

The path level configuration is a SpecificPathConfiguration. If path level configuration has never been loaded from meta master yet, it will be loaded.

Parameters:

path - the path to get the configuration for

Returns:

the path level configuration for the specific path

getMasterAddress

public InetSocketAddress getMasterAddress()
                                   throws alluxio.exception.status.UnavailableException

Returns:

the master address

Throws:

alluxio.exception.status.UnavailableException - if the master address cannot be determined

acquireMasterClientResource

public alluxio.resource.CloseableResource<FileSystemMasterClient> acquireMasterClientResource()

Acquires a file system master client from the file system master client pool. The resource is Closeable.

Returns:

the acquired file system master client resource

acquireBlockMasterClientResource

public alluxio.resource.CloseableResource<BlockMasterClient> acquireBlockMasterClientResource()

Acquires a block master client resource from the block master client pool. The resource is Closeable.

Returns:

the acquired block master client resource

acquireBlockWorkerClient

public BlockWorkerClient acquireBlockWorkerClient(alluxio.wire.WorkerNetAddress workerNetAddress)
                                           throws IOException

Acquires a block worker client from the client pools. If there is no available client instance available in the pool, it tries to create a new one. And an exception is thrown if it fails to create a new one.

Parameters:

workerNetAddress - the network address of the channel

Returns:

the acquired block worker

Throws:

IOException

releaseBlockWorkerClient

public void releaseBlockWorkerClient(alluxio.wire.WorkerNetAddress workerNetAddress,
                                     BlockWorkerClient client)

Releases a block worker client to the client pools.

Parameters:

workerNetAddress - the address of the channel

client - the client to release

hasLocalWorker

public boolean hasLocalWorker()
                       throws IOException

Returns:

if there is a local worker running the same machine

Throws:

IOException

getLocalWorker

public alluxio.wire.WorkerNetAddress getLocalWorker()
                                             throws IOException

Returns:

a local worker running the same machine, or null if none is found

Throws:

IOException