alluxio.master.file.meta

Class MountTable.State

java.lang.Object

alluxio.master.file.meta.MountTable.State

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable

Enclosing class:

MountTable

@ThreadSafe
public final class MountTable.State
extends Object
implements Journaled

Persistent mount table state. replayJournalEntryFromJournal should only be called during journal replay. To modify the mount table, create a journal entry and call one of the applyAndJournal methods.

Field Summary

Fields inherited from interface alluxio.master.journal.checkpoint.Checkpointed

LOG

Method Summary

Modifier and Type	Method and Description
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.AddMountPointEntry entry)
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, File.DeleteMountPointEntry entry)
CheckpointName	getCheckpointName()
CloseableIterator<Journal.JournalEntry>	getJournalEntryIterator()
Map<String,MountInfo>	getMountTable()
boolean	processJournalEntry(Journal.JournalEntry entry) Attempts to apply a journal entry.
void	resetState() Resets the object's journaled state.

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.Journaled

applyAndJournal, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.checkpoint.Checkpointed

restoreFromCheckpoint, writeToCheckpoint

Method Detail

getMountTable

public Map<String,MountInfo> getMountTable()

Returns:

an unmodifiable view of the mount table

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.AddMountPointEntry entry)

Parameters:

context - journal context

entry - add mount point entry

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            File.DeleteMountPointEntry entry)

Parameters:

context - journal context

entry - delete mount point entry

processJournalEntry

public boolean processJournalEntry(Journal.JournalEntry entry)

Description copied from interface: Journaled

Attempts to apply a journal entry.

Specified by:

processJournalEntry in interface Journaled

Parameters:

entry - the entry to apply

Returns:

whether the entry type is supported by this journaled object

resetState

public void resetState()

Description copied from interface: Journaled

Resets the object's journaled state.

Specified by:

resetState in interface Journaled

getJournalEntryIterator

public CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an CloseableIterator that iterates all the journal entries

getCheckpointName

public CheckpointName getCheckpointName()

Specified by:

getCheckpointName in interface Checkpointed

Returns:

a name for this checkpointed class