alluxio.underfs

Class JobUfsManager

java.lang.Object

alluxio.underfs.AbstractUfsManager

alluxio.underfs.JobUfsManager

All Implemented Interfaces:

UfsManager, Closeable, AutoCloseable

@ThreadSafe
public final class JobUfsManager
extends AbstractUfsManager

Implementation of UfsManager to manage the ufs used by different job service processes.

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
JobUfsManager() Constructs an instance of JobUfsManager.

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, getJournal, getRoot, hasMount, removeMount

Methods inherited from class java.lang.Object

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

Constructor Detail

JobUfsManager

public JobUfsManager()

Constructs an instance of JobUfsManager.

Method Detail

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

get

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

Description copied from interface: UfsManager

Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.

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