alluxio.master.journalv0

Class AsyncJournalWriter

java.lang.Object

alluxio.master.journalv0.AsyncJournalWriter

@ThreadSafe
public final class AsyncJournalWriter
extends Object

This enables async journal writing, as well as some batched journal flushing.

Constructor Summary

Constructors

Constructor and Description
AsyncJournalWriter(JournalWriter journalWriter) Creates a AsyncJournalWriter.

Method Summary

Modifier and Type	Method and Description
long	appendEntry(Journal.JournalEntry entry) Appends a Journal.JournalEntry for writing to the journal.
void	flush(long targetCounter) Flushes and waits until the specified counter is flushed to the journal.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncJournalWriter

public AsyncJournalWriter(JournalWriter journalWriter)

Creates a AsyncJournalWriter.

Parameters:

journalWriter - the JournalWriter to use for writing

Method Detail

appendEntry

public long appendEntry(Journal.JournalEntry entry)

Appends a Journal.JournalEntry for writing to the journal.

Parameters:

entry - the Journal.JournalEntry to append

Returns:

a counter for the entry, for flushing

flush

public void flush(long targetCounter)
           throws IOException

Flushes and waits until the specified counter is flushed to the journal. If the specified counter is already flushed, this is essentially a no-op.

Parameters:

targetCounter - the counter to flush

Throws:

IOException