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 SafeModeManager	mSafeModeManager The manager of safe mode state.

Fields inherited from class alluxio.master.MasterProcess

mGrpcServer, mJournalSystem, mWebServer

Method Summary

Modifier and Type	Method and Description
protected void	closeMasters() Closes all masters, including block master, fileSystem master and additional masters.
<T extends Master> T	getMaster(java.lang.Class<T> clazz)
java.net.InetSocketAddress	getRpcAddress()
java.net.InetSocketAddress	getWebAddress()
boolean	isInSafeMode()
void	start()
protected void	startJvmMonitorProcess() Starts jvm monitor process, to monitor jvm.
protected void	startMasters(boolean isLeader) Starts all masters, including block master, FileSystem master, and additional masters.
protected void	startServing(java.lang.String startMessage, java.lang.String stopMessage) Starts serving, letting MetricsSystem start sink and starting the web ui server and RPC Server.
protected void	startServingRPCServer() Starts the gRPC server.
protected void	startServingWebServer() Starts serving web ui server, resetting master web port, adding the metrics servlet to the web server and starting web ui.
void	stop()
protected void	stopMasters() Stops all masters, including block master, fileSystem master and additional masters.
protected void	stopServing() Stops serving, trying stop RPC server and web ui server and letting MetricsSystem stop all the sinks.
java.lang.String	toString()

Methods inherited from class alluxio.master.MasterProcess

getStartTimeMs, getUptimeMs, isServing, startRejectingServers, startServing, stopRejectingRpcServer, stopRejectingServers, stopRejectingWebServer, waitForReady

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.

Method Detail

getMaster

public <T extends Master> T getMaster(java.lang.Class<T> clazz)

Specified by:

getMaster in class MasterProcess

isInSafeMode

public boolean isInSafeMode()

Returns:

true if Alluxio is running in safe mode, false otherwise

getWebAddress

@Nullable
public java.net.InetSocketAddress getWebAddress()

Specified by:

getWebAddress in class MasterProcess

getRpcAddress

public java.net.InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in class MasterProcess

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Throws:

java.lang.Exception

startMasters

protected void startMasters(boolean isLeader)

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

Parameters:

isLeader - if the Master is leader

stopMasters

protected void stopMasters()

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

closeMasters

protected void closeMasters()

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

startServingWebServer

protected void startServingWebServer()

Starts serving web ui server, resetting master web port, adding the metrics servlet to the web server and starting web ui.

startJvmMonitorProcess

protected void startJvmMonitorProcess()

Starts jvm monitor process, to monitor jvm.

startServing

protected void startServing(java.lang.String startMessage,
                            java.lang.String stopMessage)

Starts serving, letting MetricsSystem start sink and starting the web ui server and RPC Server.

Specified by:

startServing in class MasterProcess

Parameters:

startMessage - empty string or the message that the master gains the leadership

stopMessage - empty string or the message that the master loses the leadership

startServingRPCServer

protected void startServingRPCServer()

Starts the gRPC server. The AlluxioMaster registers the Services of registered Masters and meta services.

stopServing

protected void stopServing()
                    throws java.lang.Exception

Stops serving, trying stop RPC server and web ui server and letting MetricsSystem stop all the sinks.

Throws:

java.lang.Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object