alluxio.underfs

Class MasterUfsManager

java.lang.Object

alluxio.underfs.AbstractUfsManager

alluxio.underfs.MasterUfsManager

All Implemented Interfaces:

JournalEntryIterable, UfsManager, Closeable, AutoCloseable

@ThreadSafe
public final class MasterUfsManager
extends AbstractUfsManager
implements JournalEntryIterable

A class that manages the UFS for master servers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterUfsManager.UfsState UnderFileSystem.UfsMode and mount ids corresponding to a physical ufs.

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
MasterUfsManager() Constructs the instance of MasterUfsManager.

Method Summary

Modifier and Type	Method and Description
void	addMount(long mountId, AlluxioURI ufsUri, UnderFileSystemConfiguration ufsConf) Keeps track of a mount id and maps it to its URI in Alluxio and configuration.
protected void	connectUfs(UnderFileSystem fs) Takes any necessary actions required to establish a connection to the under file system.
Iterator<Journal.JournalEntry>	getJournalEntryIterator()
Map<String,UnderFileSystem.UfsMode>	getPhysicalUfsState(List<String> physicalStores) Get the physical ufs operation modes for the UnderFileSystem under the given Mount table resolution.
void	removeMount(long mountId) Removes the association from a mount id to a UFS instance.
void	setUfsMode(AlluxioURI ufsPath, UnderFileSystem.UfsMode ufsMode, RpcContext rpcContext) Set the operation mode the given physical ufs.

Methods inherited from class alluxio.underfs.AbstractUfsManager

close, get, getRoot

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterUfsManager

public MasterUfsManager()

Constructs the instance of MasterUfsManager.

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

addMount

public void addMount(long mountId,
                     AlluxioURI ufsUri,
                     UnderFileSystemConfiguration ufsConf)

Description copied from interface: UfsManager

Keeps track of a mount id and maps it to its URI in Alluxio and configuration. This is an Alluxio-only operation and no interaction to UFS will be made.

Specified by:

addMount in interface UfsManager

Overrides:

addMount in class AbstractUfsManager

Parameters:

mountId - the mount id

ufsUri - the UFS path

ufsConf - the UFS configuration

removeMount

public void removeMount(long mountId)

Description copied from interface: UfsManager

Removes the association from a mount id to a UFS instance. If the mount id is not known, this is a noop.

Specified by:

removeMount in interface UfsManager

Overrides:

removeMount in class AbstractUfsManager

Parameters:

mountId - the mount id

getPhysicalUfsState

public Map<String,UnderFileSystem.UfsMode> getPhysicalUfsState(List<String> physicalStores)

Get the physical ufs operation modes for the UnderFileSystem under the given Mount table resolution.

Parameters:

physicalStores - the physical stores for the mount resolution

Returns:

the state of physical UFS for given mount resolution

setUfsMode

public void setUfsMode(AlluxioURI ufsPath,
                       UnderFileSystem.UfsMode ufsMode,
                       RpcContext rpcContext)
                throws InvalidPathException

Set the operation mode the given physical ufs.

Parameters:

ufsPath - the physical ufs path (scheme and authority only)

ufsMode - the ufs operation mode

rpcContext - rpc context

Throws:

InvalidPathException - if no managed ufs covers the given path

getJournalEntryIterator

public Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an Iterator that iterates all the journal entries