alluxio.master.journal

Interface NoopJournaled

All Superinterfaces:

Checkpointed, Journaled, JournalEntryIterable

All Known Implementing Classes:

DefaultMetricsMaster, JobMaster, NoopMaster

public interface NoopJournaled
extends Journaled

Interface providing default implementations which do nothing.

Method Summary

Modifier and Type	Method and Description
default CheckpointName	getCheckpointName()
default CloseableIterator<Journal.JournalEntry>	getJournalEntryIterator()
default boolean	processJournalEntry(Journal.JournalEntry entry) Attempts to apply a journal entry.
default void	resetState() Resets the object's journaled state.
default void	restoreFromCheckpoint(CheckpointInputStream input) Restores state from a checkpoint.
default void	writeToCheckpoint(OutputStream output) Writes a checkpoint of all state to the given output stream.

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal

Method Detail

processJournalEntry

default 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

default void resetState()

Description copied from interface: Journaled

Resets the object's journaled state.

Specified by:

resetState in interface Journaled

getCheckpointName

default CheckpointName getCheckpointName()

Specified by:

getCheckpointName in interface Checkpointed

Returns:

a name for this checkpointed class

writeToCheckpoint

default void writeToCheckpoint(OutputStream output)
                        throws IOException

Description copied from interface: Checkpointed

Writes a checkpoint of all state to the given output stream. Implementations should make an effort to throw InterruptedException if they get interrupted while running.

Specified by:

writeToCheckpoint in interface Checkpointed

Specified by:

writeToCheckpoint in interface Journaled

Parameters:

output - the output stream to write to

Throws:

IOException

restoreFromCheckpoint

default void restoreFromCheckpoint(CheckpointInputStream input)

Description copied from interface: Checkpointed

Restores state from a checkpoint.

Specified by:

restoreFromCheckpoint in interface Checkpointed

Specified by:

restoreFromCheckpoint in interface Journaled

Parameters:

input - an input stream with checkpoint data

getJournalEntryIterator

default CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an CloseableIterator that iterates all the journal entries