alluxio.master

Class MasterProcess

java.lang.Object

alluxio.master.MasterProcess

All Implemented Interfaces:

Process

Direct Known Subclasses:

AlluxioJobMasterProcess, AlluxioMasterProcess

public abstract class MasterProcess
extends Object
implements Process

Defines a set of methods which any MasterProcess should implement. This class serves as a common implementation for functions that both the AlluxioMasterProcess and AlluxioJobMasterProcess use. Each master should have an RPC server, web server, and journaling system which can serve client requests.

Field Summary

Fields

Modifier and Type	Field and Description
protected GrpcServer	mGrpcServer The RPC server.
protected JournalSystem	mJournalSystem The journal system for writing journal entries and restoring master state.
protected WebServer	mWebServer The web ui server.

Constructor Summary

Constructors

Constructor and Description
MasterProcess(JournalSystem journalSystem, NetworkAddressUtils.ServiceType rpcService, NetworkAddressUtils.ServiceType webService) Prepares a MasterProcess journal, rpc and web server using the given sockets.

Method Summary

Modifier and Type	Method and Description
abstract <T extends Master> T	getMaster(Class<T> clazz) Gets the registered class from the master registry.
abstract InetSocketAddress	getRpcAddress()
long	getStartTimeMs()
long	getUptimeMs()
abstract InetSocketAddress	getWebAddress()
boolean	isServing()
protected void	startRejectingServers()
protected void	startServing()
protected void	stopRejectingRpcServer()
protected void	stopRejectingServers()
protected void	stopRejectingWebServer()
boolean	waitForReady(int timeoutMs) Waits until the process is ready to serve requests.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.Process

start, stop

Field Detail

mJournalSystem

protected final JournalSystem mJournalSystem

The journal system for writing journal entries and restoring master state.

mGrpcServer

protected GrpcServer mGrpcServer

The RPC server.

mWebServer

protected WebServer mWebServer

The web ui server.

Constructor Detail

MasterProcess

public MasterProcess(JournalSystem journalSystem,
                     NetworkAddressUtils.ServiceType rpcService,
                     NetworkAddressUtils.ServiceType webService)

Prepares a MasterProcess journal, rpc and web server using the given sockets.

Parameters:

journalSystem - the journaling system

rpcService - the rpc service type

webService - the web service type

Method Detail

getRpcAddress

public abstract InetSocketAddress getRpcAddress()

Returns:

this master's rpc address

getMaster

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

Gets the registered class from the master registry.

Type Parameters:

T - the type of the master to get

Parameters:

clazz - the class of the master to get

Returns:

the given master

getStartTimeMs

public long getStartTimeMs()

Returns:

the start time of the master in milliseconds

startServing

protected void startServing()

getUptimeMs

public long getUptimeMs()

Returns:

the uptime of the master in milliseconds

getWebAddress

public abstract InetSocketAddress getWebAddress()

Returns:

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

isServing

public boolean isServing()

Returns:

true if the system is the leader (serving the rpc server), false otherwise

waitForReady

public boolean waitForReady(int timeoutMs)

Description copied from interface: Process

Waits until the process is ready to serve requests.

Specified by:

waitForReady in interface Process

Parameters:

timeoutMs - how long to wait in milliseconds

Returns:

whether the process became ready before the specified timeout

startRejectingServers

protected void startRejectingServers()

stopRejectingRpcServer

protected void stopRejectingRpcServer()

stopRejectingWebServer

protected void stopRejectingWebServer()

stopRejectingServers

protected void stopRejectingServers()