alluxio.master.journal

Class MasterJournalContext

java.lang.Object

alluxio.master.journal.MasterJournalContext

All Implemented Interfaces:

JournalContext, Closeable, AutoCloseable, java.util.function.Supplier<JournalContext>

@ThreadSafe
public final class MasterJournalContext
extends Object
implements JournalContext

Context for storing master journal information. This journal context is made thread-safe because metadata sync creates worker threads to fetch metadata and reuses the same journal context.

Constructor Summary

Constructors

Constructor and Description
MasterJournalContext(AsyncJournalWriter asyncJournalWriter) Constructs a MasterJournalContext.

Method Summary

Modifier and Type	Method and Description
void	append(Journal.JournalEntry entry)
void	close()
void	flush() Flushes all the entries appended by the journal context so far.

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

get

Constructor Detail

MasterJournalContext

public MasterJournalContext(AsyncJournalWriter asyncJournalWriter)

Constructs a MasterJournalContext.

Parameters:

asyncJournalWriter - a AsyncJournalWriter

Method Detail

append

public void append(Journal.JournalEntry entry)

Specified by:

append in interface JournalContext

Parameters:

entry - the Journal.JournalEntry to append to the journal

flush

public void flush()
           throws UnavailableException

Description copied from interface: JournalContext

Flushes all the entries appended by the journal context so far. This method can be called multiple times within the life cycle of the journal context The journals will be committed synchronously (example MasterJournalContext, or only added into the async journal writer (example MetadataSyncMergeJournalContext, based on different implementations.

Specified by:

flush in interface JournalContext

Throws:

UnavailableException

close

public void close()
           throws UnavailableException

Specified by:

close in interface JournalContext

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

UnavailableException