alluxio.master.journal

Class AbstractJournalSystem

java.lang.Object

alluxio.master.journal.AbstractJournalSystem

All Implemented Interfaces:

JournalSystem

Direct Known Subclasses:

RaftJournalSystem, UfsJournalSystem

@ThreadSafe
public abstract class AbstractJournalSystem
extends Object
implements JournalSystem

Base implementation for journal systems.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.journal.JournalSystem

JournalSystem.Builder, JournalSystem.Mode

Constructor Summary

Constructors

Constructor and Description
AbstractJournalSystem()

Method Summary

Modifier and Type	Method and Description
void	addJournalSink(Master master, JournalSink journalSink)
Set<JournalSink>	getJournalSinks(Master master)
void	removeJournalSink(Master master, JournalSink journalSink)
void	start() Starts the journal system.
protected abstract void	startInternal() Starts the journal system.
void	stop() Stops the journal system.
protected abstract void	stopInternal() Stops the journal system.

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

catchup, checkpoint, createJournal, format, gainPrimacy, getCurrentSequenceNumbers, getJournalServices, isEmpty, isFormatted, losePrimacy, resume, suspend

Constructor Detail

AbstractJournalSystem

public AbstractJournalSystem()

Method Detail

start

public void start()
           throws InterruptedException,
                  IOException

Description copied from interface: JournalSystem

Starts the journal system. All journals must be created before starting the journal system. This method will block until the journal system is successfully started. The journal always starts in secondary mode.

Specified by:

start in interface JournalSystem

Throws:

InterruptedException

IOException

stop

public void stop()
          throws InterruptedException,
                 IOException

Description copied from interface: JournalSystem

Stops the journal system.

Specified by:

stop in interface JournalSystem

Throws:

InterruptedException

IOException

addJournalSink

public void addJournalSink(Master master,
                           JournalSink journalSink)

Specified by:

addJournalSink in interface JournalSystem

Parameters:

master - the master for which to add the journal sink

journalSink - the journal sink to add

removeJournalSink

public void removeJournalSink(Master master,
                              JournalSink journalSink)

Specified by:

removeJournalSink in interface JournalSystem

Parameters:

master - the master from which to remove the journal sink

journalSink - the journal sink to remove

getJournalSinks

public Set<JournalSink> getJournalSinks(@Nullable
                                        Master master)

Specified by:

getJournalSinks in interface JournalSystem

Parameters:

master - the master to get the journal sinks for, or null to get all sinks

Returns:

a set of JournalSink for the given master, or all sinks if master is null

startInternal

protected abstract void startInternal()
                               throws InterruptedException,
                                      IOException

Starts the journal system.

Throws:

InterruptedException

IOException

stopInternal

protected abstract void stopInternal()
                              throws InterruptedException,
                                     IOException

Stops the journal system.

Throws:

InterruptedException

IOException