alluxio.master.journal

Interface NoopJournaled

All Superinterfaces:

Checkpointed, Journaled, JournalEntryIterable

All Known Implementing Classes:

DefaultJournalMaster, DefaultMetricsMaster, JobMaster, NoopMaster

public interface NoopJournaled
extends Journaled

Interface providing default implementations which do nothing.

Field Summary

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

LOG

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 CompletableFuture<Void>	restoreFromCheckpoint(File directory, ExecutorService executorService) Restores state from a checkpoint asynchronously.
default CompletableFuture<Void>	writeToCheckpoint(File directory, ExecutorService executorService) Writes a checkpoint to the specified directory asynchronously using the provided executor.
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 CompletableFuture<Void> writeToCheckpoint(File directory,
                                                  ExecutorService executorService)

Description copied from interface: Checkpointed

Writes a checkpoint to the specified directory asynchronously using the provided executor.

Specified by:

writeToCheckpoint in interface Checkpointed

Parameters:

directory - where the checkpoint will be written

executorService - to use when running tasks asynchronously

Returns:

a future that processes the computation

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 CompletableFuture<Void> restoreFromCheckpoint(File directory,
                                                      ExecutorService executorService)

Description copied from interface: Checkpointed

Restores state from a checkpoint asynchronously.

Specified by:

restoreFromCheckpoint in interface Checkpointed

Parameters:

directory - where the checkpoint will be located

executorService - to use when running asynchronous tasks

Returns:

a future to track the progress

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