alluxio.underfs

Class MasterUfsManager

java.lang.Object

alluxio.underfs.AbstractUfsManager

alluxio.underfs.MasterUfsManager

All Implemented Interfaces:

Checkpointed, DelegatingJournaled, Journaled, JournalEntryIterable, UfsManager, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class MasterUfsManager
extends AbstractUfsManager
implements DelegatingJournaled

A class that manages the UFS for master servers.

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

Method Summary

Modifier and Type	Method and Description
void	addMount(long mountId, AlluxioURI ufsUri, UnderFileSystemConfiguration ufsConf)
protected void	connectUfs(UnderFileSystem fs)
Journaled	getDelegate()
CloseableIterator<Journal.JournalEntry>	getJournalEntryIterator()
java.util.Map<java.lang.String,UfsMode>	getPhysicalUfsState(java.util.List<java.lang.String> physicalStores) Get the physical ufs operation modes for the UnderFileSystem under the given Mount table resolution.
void	removeMount(long mountId)
void	setUfsMode(java.util.function.Supplier<JournalContext> journalContext, AlluxioURI ufsPath, UfsMode ufsMode) 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

Methods inherited from interface alluxio.master.journal.DelegatingJournaled

applyAndJournal, getCheckpointName, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Constructor Detail

MasterUfsManager

public MasterUfsManager()

Constructs the instance of MasterUfsManager.

Method Detail

connectUfs

protected void connectUfs(UnderFileSystem fs)
                   throws java.io.IOException

Specified by:

connectUfs in class AbstractUfsManager

Throws:

java.io.IOException

addMount

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

Specified by:

addMount in interface UfsManager

Overrides:

addMount in class AbstractUfsManager

removeMount

public void removeMount(long mountId)

Specified by:

removeMount in interface UfsManager

Overrides:

removeMount in class AbstractUfsManager

getPhysicalUfsState

public java.util.Map<java.lang.String,UfsMode> getPhysicalUfsState(java.util.List<java.lang.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(java.util.function.Supplier<JournalContext> journalContext,
                       AlluxioURI ufsPath,
                       UfsMode ufsMode)
                throws InvalidPathException

Set the operation mode the given physical ufs.

Parameters:

journalContext - the journal context

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

ufsMode - the ufs operation mode

Throws:

InvalidPathException - if no managed ufs covers the given path

getDelegate

public Journaled getDelegate()

Specified by:

getDelegate in interface DelegatingJournaled

getJournalEntryIterator

public CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface DelegatingJournaled

Specified by:

getJournalEntryIterator in interface JournalEntryIterable