alluxio.master

Class AbstractMaster

java.lang.Object

alluxio.master.AbstractMaster

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable, Master, Server<Boolean>

Direct Known Subclasses:

CoreMaster, DefaultJournalMaster, JobMaster

@NotThreadSafe
public abstract class AbstractMaster
extends Object
implements Master

This is the base class for all masters, and contains common functionality. Common functionality mostly consists of journal operations, like initialization, journal tailing when in standby mode, or journal writing when the master is the primary.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.time.Clock	mClock The clock to use for determining the time.
protected Journal	mJournal A handler to the journal for this master.
protected MasterContext	mMasterContext The context of Alluxio masters.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMaster(MasterContext masterContext, java.time.Clock clock, ExecutorServiceFactory executorServiceFactory)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the server.
JournalContext	createJournalContext()
Set<Class<? extends Server>>	getDependencies()
protected ExecutorService	getExecutorService()
MasterContext	getMasterContext()
void	start(Boolean isPrimary) Starts the Alluxio server.
void	stop() Stops the Alluxio server.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.Master

getStandbyServices

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

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

getCheckpointName, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

getName, getServices

Field Detail

mJournal

protected final Journal mJournal

A handler to the journal for this master.

mClock

protected final java.time.Clock mClock

The clock to use for determining the time.

mMasterContext

protected final MasterContext mMasterContext

The context of Alluxio masters.

Constructor Detail

AbstractMaster

protected AbstractMaster(MasterContext masterContext,
                         java.time.Clock clock,
                         ExecutorServiceFactory executorServiceFactory)

Parameters:

masterContext - the context for Alluxio master

clock - the Clock to use for determining the time

executorServiceFactory - a factory for creating the executor service to use for running maintenance threads

Method Detail

getDependencies

public Set<Class<? extends Server>> getDependencies()

Specified by:

getDependencies in interface Server<Boolean>

Returns:

the server dependencies

start

public void start(Boolean isPrimary)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<Boolean>

Parameters:

isPrimary - the start options

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: Server

Stops the Alluxio server. Here, anything created or started in #start(T) should be cleaned up and shutdown.

Specified by:

stop in interface Server<Boolean>

Throws:

IOException

getExecutorService

protected ExecutorService getExecutorService()

Returns:

the ExecutorService for this master

createJournalContext

public JournalContext createJournalContext()
                                    throws UnavailableException

Specified by:

createJournalContext in interface Master

Returns:

a journal context for writing journal entries to the master

Throws:

UnavailableException

close

public void close()
           throws IOException

Description copied from interface: Server

Closes the server.

Specified by:

close in interface Server<Boolean>

Throws:

IOException

getMasterContext

public MasterContext getMasterContext()

Specified by:

getMasterContext in interface Master

Returns:

a master context