alluxio.master.journal

Class SingleEntryJournaled

java.lang.Object

alluxio.master.journal.SingleEntryJournaled

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable

Direct Known Subclasses:

DefaultBlockMasterContainerIdJournaled, SnapshotIdJournaled

public abstract class SingleEntryJournaled
extends Object
implements Journaled

Journaled component responsible for journaling a single journal entry.

Field Summary

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

LOG

Constructor Summary

Constructors

Constructor and Description
SingleEntryJournaled()

Method Summary

Modifier and Type	Method and Description
Journal.JournalEntry	getEntry()
CloseableIterator<Journal.JournalEntry>	getJournalEntryIterator()
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

getCheckpointName, restoreFromCheckpoint, writeToCheckpoint

Constructor Detail

SingleEntryJournaled

public SingleEntryJournaled()

Method Detail

getJournalEntryIterator

public CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an CloseableIterator that iterates all the journal entries

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

getEntry

public Journal.JournalEntry getEntry()

Returns:

the entry stored by this object