alluxio.master

Class AlluxioMasterProcess

java.lang.Object

alluxio.master.MasterProcess

alluxio.master.AlluxioMasterProcess

All Implemented Interfaces:

Process

@NotThreadSafe
public class AlluxioMasterProcess
extends MasterProcess

An Alluxio Master which runs a web and rpc server to handle FileSystem operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AlluxioMasterProcess.Factory Factory for creating AlluxioMasterProcess.

Field Summary

Fields

Modifier and Type	Field and Description
protected CoreMasterContext	mContext Master context.
protected AtomicBoolean	mIsStopped See isStopped().
protected SafeModeManager	mSafeModeManager The manager of safe mode state.

Fields inherited from class alluxio.master.MasterProcess

mJournalSystem, mLeaderSelector, mRegistry

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AlluxioMasterProcess(JournalSystem journalSystem, PrimarySelector leaderSelector) Creates a new AlluxioMasterProcess.

Method Summary

Modifier and Type	Method and Description
protected CoreMasterContext.Builder	createBaseMasterContext()
GrpcServerBuilder	createBaseRpcServer()
Optional<AlluxioExecutorService>	createRpcExecutorService() This method is decoupled from MasterProcess.createBaseRpcServer() because the AlluxioExecutorService needs to be managed (i.e.
WebServer	createWebServer()
Optional<SafeModeManager>	getSafeModeManager()
boolean	isInSafeMode()
boolean	isStopped() Indicates if all master resources have been successfully released when stopping.
void	start() Starts the Alluxio process.
protected void	startMasterComponents(boolean isLeader) Starts all masters, including block master, FileSystem master, and additional masters.
void	stop() Stops the Alluxio process, blocking until the action is completed.
protected void	stopMasterComponents() Stops all masters, including block master, fileSystem master and additional masters.
protected void	takeEmergencyBackup()
String	toString()

Methods inherited from class alluxio.master.MasterProcess

getMaster, getPrimarySelector, getRegistry, getRpcAddress, getRpcBindAddress, getStartTimeMs, getUptimeMs, getWebAddress, getWebBindAddress, isGrpcServingAsLeader, isMetricSinkServing, isWebServing, registerService, waitForLeaderGrpcServerReady, waitForMetricSinkServing, waitForReady, waitForWebServerReady

Methods inherited from class java.lang.Object

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

Field Detail

mSafeModeManager

protected final SafeModeManager mSafeModeManager

The manager of safe mode state.

mContext

protected final CoreMasterContext mContext

Master context.

mIsStopped

protected final AtomicBoolean mIsStopped

See isStopped().

Constructor Detail

AlluxioMasterProcess

protected AlluxioMasterProcess(JournalSystem journalSystem,
                               PrimarySelector leaderSelector)

Creates a new AlluxioMasterProcess.

Method Detail

createBaseMasterContext

protected CoreMasterContext.Builder createBaseMasterContext()

createWebServer

public WebServer createWebServer()

Specified by:

createWebServer in class MasterProcess

Returns:

a newly created web server for this master

createBaseRpcServer

public GrpcServerBuilder createBaseRpcServer()

Specified by:

createBaseRpcServer in class MasterProcess

Returns:

a fully configured rpc server except for the executor option (provided by the MasterProcess.createRpcExecutorService()) and the rpc services (provided by MasterProcess.mRegistry

createRpcExecutorService

public Optional<AlluxioExecutorService> createRpcExecutorService()

Description copied from class: MasterProcess

This method is decoupled from MasterProcess.createBaseRpcServer() because the AlluxioExecutorService needs to be managed (i.e. started and stopped) independently of the rpc server that uses it

Overrides:

createRpcExecutorService in class MasterProcess

Returns:

a custom executor service to be used in the rpc server

getSafeModeManager

public Optional<SafeModeManager> getSafeModeManager()

Overrides:

getSafeModeManager in class MasterProcess

Returns:

the SafeModeManager if you have one

isInSafeMode

public boolean isInSafeMode()

Returns:

true if Alluxio is running in safe mode, false otherwise

start

public void start()
           throws Exception

Description copied from interface: Process

Starts the Alluxio process. This call blocks until the process is stopped via Process.stop(). The Process.waitForReady(int) method can be used to make sure that the process is ready to serve requests.

Throws:

Exception

takeEmergencyBackup

protected void takeEmergencyBackup()
                            throws AlluxioException,
                                   InterruptedException,
                                   TimeoutException

Throws:

AlluxioException

InterruptedException

TimeoutException

startMasterComponents

protected void startMasterComponents(boolean isLeader)
                              throws IOException

Starts all masters, including block master, FileSystem master, and additional masters.

Parameters:

isLeader - if the Master is leader

Throws:

IOException

stopMasterComponents

protected void stopMasterComponents()

Stops all masters, including block master, fileSystem master and additional masters.

stop

public void stop()
          throws Exception

Description copied from interface: Process

Stops the Alluxio process, blocking until the action is completed.

Throws:

Exception

isStopped

public boolean isStopped()

Indicates if all master resources have been successfully released when stopping. An assumption made here is that a first call to stop() might fail while a second call might succeed.

Returns:

whether stop() has concluded successfully at least once

toString

public String toString()

Overrides:

toString in class Object