alluxio.master

Class AbstractMaster

java.lang.Object

alluxio.master.AbstractMaster

All Implemented Interfaces:

JournalEntryIterable, JournalEntryStateMachine, Master, Server<Boolean>

Direct Known Subclasses:

DefaultBlockMaster, DefaultFileSystemMaster, DefaultKeyValueMaster, DefaultLineageMaster, DefaultMetaMaster, DefaultMetricsMaster

@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 secondary mode, or journal writing when the master is the primary.

Field Summary

Fields

Modifier and Type	Field and Description
protected BackupManager	mBackupManager The manager for creating and restoring backups.
protected java.time.Clock	mClock The clock to use for determining the time.
protected Lock	mPauseStateLock A lock which prevents any changes to persistent (journaled) state.
protected SafeModeManager	mSafeModeManager The manager for safe mode state.
protected Lock	mStateChangeLock A lock which must be taken before modifying persistent (journaled) state.

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
JournalContext	createJournalContext()
Set<Class<? extends Server>>	getDependencies()
protected ExecutorService	getExecutorService()
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.journal.JournalEntryStateMachine

getName, processJournalEntry, resetState

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

getName, getServices

Field Detail

mClock

protected final java.time.Clock mClock

The clock to use for determining the time.

mSafeModeManager

protected final SafeModeManager mSafeModeManager

The manager for safe mode state.

mBackupManager

protected final BackupManager mBackupManager

The manager for creating and restoring backups.

mStateChangeLock

protected final Lock mStateChangeLock

A lock which must be taken before modifying persistent (journaled) state. This is a counterpart to mPauseStateLock.

mPauseStateLock

protected final Lock mPauseStateLock

A lock which prevents any changes to persistent (journaled) state. This is a counterpart to mStateChangeLock.

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