alluxio.master.journal.raft

Class RaftJournal

java.lang.Object

alluxio.master.journal.raft.RaftJournal

All Implemented Interfaces:

Journal, Closeable, AutoCloseable

@NotThreadSafe
public class RaftJournal
extends Object
implements Journal

Class associated with each master that lets the master create journal contexts for writing entries to the journal.

Constructor Summary

Constructors

Constructor and Description
RaftJournal(Journaled stateMachine, URI location, AtomicReference<AsyncJournalWriter> journalWriter)

Method Summary

Modifier and Type	Method and Description
void	close()
JournalContext	createJournalContext()
URI	getLocation()
Journaled	getStateMachine()

Methods inherited from class java.lang.Object

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

Constructor Detail

RaftJournal

public RaftJournal(Journaled stateMachine,
                   URI location,
                   AtomicReference<AsyncJournalWriter> journalWriter)

Parameters:

stateMachine - the state machine for this journal

location - the location of the raft journal

journalWriter - reference to the journal writer to use for writing to the journal

Method Detail

getStateMachine

public Journaled getStateMachine()

Returns:

the state machine for this journal

getLocation

public URI getLocation()

Specified by:

getLocation in interface Journal

Returns:

the journal location

createJournalContext

public JournalContext createJournalContext()
                                    throws UnavailableException

Specified by:

createJournalContext in interface Journal

Returns:

a journal context for appending journal entries

Throws:

UnavailableException - if a context cannot be created because the journal has been closed.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException