alluxio.master

Class AlluxioSimpleMasterProcess

java.lang.Object

alluxio.master.MasterProcess

alluxio.master.AlluxioSimpleMasterProcess

All Implemented Interfaces:

Process

Direct Known Subclasses:

AlluxioJobMasterProcess

@NotThreadSafe
public abstract class AlluxioSimpleMasterProcess
extends MasterProcess

This class is responsible for initializing the different masters that are configured to run.

Field Summary

Fields inherited from class alluxio.master.MasterProcess

mGrpcServer, mGrpcServerLock, mJournalSystem, mLeaderSelector, mServingThread, mServingThreadTimeoutMs, mWebServer, mWebServerLock

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getRpcAddress()
InetSocketAddress	getWebAddress()
void	start() Starts the Alluxio process.
protected void	startMaster(boolean isLeader)
protected void	startServing(String startMessage, String stopMessage)
protected void	startServingRPCServer() Starts the gRPC server.
protected void	startServingWebServer()
void	stop() Stops the Alluxio master server.
protected void	stopMaster()
protected void	stopServing()
String	toString()

Methods inherited from class alluxio.master.MasterProcess

getMaster, getStartTimeMs, getUptimeMs, isGrpcServing, isMetricSinkServing, isWebServing, startRejectingServers, startServing, stopRejectingRpcServer, stopRejectingServers, stopRejectingWebServer, waitForGrpcServerReady, waitForMetricSinkServing, waitForReady, waitForWebServerReady

Methods inherited from class java.lang.Object

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

Method Detail

getWebAddress

public InetSocketAddress getWebAddress()

Specified by:

getWebAddress in class MasterProcess

Returns:

the master's web address

getRpcAddress

public InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in class MasterProcess

Returns:

this master's rpc address

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

stop

public void stop()
          throws Exception

Stops the Alluxio master server.

Throws:

Exception - if stopping the master fails

startMaster

protected void startMaster(boolean isLeader)

stopMaster

protected void stopMaster()

startServing

protected void startServing(String startMessage,
                            String stopMessage)

startServingWebServer

protected void startServingWebServer()

startServingRPCServer

protected void startServingRPCServer()

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

stopServing

protected void stopServing()
                    throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object