alluxio.master

Class AlluxioJobMasterProcess

java.lang.Object

alluxio.master.MasterProcess

alluxio.master.AlluxioJobMasterProcess

All Implemented Interfaces:

Process

@NotThreadSafe
public class AlluxioJobMasterProcess
extends MasterProcess

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

Field Summary

Fields

Modifier and Type	Field and Description
protected JobMaster	mJobMaster The master managing all job related metadata.

Fields inherited from class alluxio.master.MasterProcess

mGrpcServer, mJournalSystem, mWebServer

Method Summary

Modifier and Type	Method and Description
JobMaster	getJobMaster()
<T extends Master> T	getMaster(Class<T> clazz) Gets the registered class from the master registry.
InetSocketAddress	getRpcAddress()
InetSocketAddress	getWebAddress()
void	start() Starts the Alluxio job master server.
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 job master server.
protected void	stopMaster()
protected void	stopServing()
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

mJobMaster

protected JobMaster mJobMaster

The master managing all job related metadata.

Method Detail

getMaster

public <T extends Master> T getMaster(Class<T> clazz)

Description copied from class: MasterProcess

Gets the registered class from the master registry.

Specified by:

getMaster in class MasterProcess

Type Parameters:

T - the type of the master to get

Parameters:

clazz - the class of the master to get

Returns:

the given master

getJobMaster

public JobMaster getJobMaster()

Returns:

the JobMaster for this process

getWebAddress

@Nullable
public InetSocketAddress getWebAddress()

Specified by:

getWebAddress in class MasterProcess

Returns:

the master's web address, or null if the web server hasn't been started yet

getRpcAddress

public InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in class MasterProcess

Returns:

this master's rpc address

start

public void start()
           throws Exception

Starts the Alluxio job master server.

Throws:

Exception - if starting the master fails

stop

public void stop()
          throws Exception

Stops the Alluxio job 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