alluxio.master

Class AlluxioJobMasterProcess

java.lang.Object

alluxio.master.MasterProcess

alluxio.master.AlluxioSimpleMasterProcess

alluxio.master.AlluxioJobMasterProcess

All Implemented Interfaces:

Process

@NotThreadSafe
public class AlluxioJobMasterProcess
extends AlluxioSimpleMasterProcess

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

Field Summary

Fields inherited from class alluxio.master.MasterProcess

mJournalSystem, mLeaderSelector, mRegistry

Method Summary

Modifier and Type	Method and Description
GrpcServerBuilder	createBaseRpcServer()
WebServer	createWebServer()
JobMaster	getJobMaster()

Methods inherited from class alluxio.master.AlluxioSimpleMasterProcess

start, startMasterComponents, stop, stopMasterComponents, toString

Methods inherited from class alluxio.master.MasterProcess

createRpcExecutorService, getMaster, getPrimarySelector, getRegistry, getRpcAddress, getRpcBindAddress, getSafeModeManager, 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

Method Detail

getJobMaster

public JobMaster getJobMaster()

Returns:

the JobMaster for this process

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