alluxio.underfs

Class WorkerUfsManager

java.lang.Object

alluxio.underfs.AbstractUfsManager

alluxio.underfs.WorkerUfsManager

All Implemented Interfaces:

UfsManager, Closeable, AutoCloseable

@ThreadSafe
public final class WorkerUfsManager
extends AbstractUfsManager

The default implementation of UfsManager to manage the ufs used by different worker services.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.underfs.AbstractUfsManager

AbstractUfsManager.Key

Nested classes/interfaces inherited from interface alluxio.underfs.UfsManager

UfsManager.UfsClient

Field Summary

Fields inherited from class alluxio.underfs.AbstractUfsManager

mCloser, mUnderFileSystemMap

Constructor Summary

Constructors

Constructor and Description
WorkerUfsManager(FileSystemMasterClient masterClient) Constructs an instance of WorkerUfsManager.

Method Summary

Modifier and Type	Method and Description
protected void	connectUfs(UnderFileSystem fs) Takes any necessary actions required to establish a connection to the under file system.
UfsManager.UfsClient	get(long mountId) Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.

Methods inherited from class alluxio.underfs.AbstractUfsManager

addMount, addMountWithRecorder, close, generateKey, get, get, getJournal, getOrAdd, getRoot, hasMount, removeMount

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerUfsManager

@Inject
public WorkerUfsManager(FileSystemMasterClient masterClient)

Constructs an instance of WorkerUfsManager.

Parameters:

masterClient - the file system master client

Method Detail

get

public UfsManager.UfsClient get(long mountId)
                         throws NotFoundException,
                                UnavailableException

Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.. If this mount id is new to this worker, this method will query master to get the corresponding ufs info.

Specified by:

get in interface UfsManager

Overrides:

get in class AbstractUfsManager

Parameters:

mountId - the mount id

Returns:

the UFS information

Throws:

NotFoundException - if mount id is not found in mount table

UnavailableException - if master is not available to query for mount table

connectUfs

protected void connectUfs(UnderFileSystem fs)
                   throws IOException

Description copied from class: AbstractUfsManager

Takes any necessary actions required to establish a connection to the under file system. The implementation will either call UnderFileSystem.connectFromMaster(String) or UnderFileSystem.connectFromWorker(String) depending on the running process.

Specified by:

connectUfs in class AbstractUfsManager

Throws:

IOException