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

public static final class MountTable.State
extends java.lang.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.

Constructor Summary

Constructors

Constructor and Description
State(MountInfo mountInfo)

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()
java.util.Iterator<Journal.JournalEntry>	getJournalEntryIterator()
java.util.Map<java.lang.String,MountInfo>	getMountTable()
boolean	processJournalEntry(Journal.JournalEntry entry)
void	resetState()

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

Constructor Detail

State

public State(MountInfo mountInfo)

Parameters:

mountInfo - root mount info

Method Detail

getMountTable

public java.util.Map<java.lang.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)

Specified by:

processJournalEntry in interface Journaled

resetState

public void resetState()

Specified by:

resetState in interface Journaled

getJournalEntryIterator

public java.util.Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

getCheckpointName

public CheckpointName getCheckpointName()

Specified by:

getCheckpointName in interface Checkpointed