@NotThreadSafe public class AlluxioJobMasterProcess extends AlluxioSimpleMasterProcess
mJournalSystem, mLeaderSelector, mRegistry
Modifier and Type | Method and Description |
---|---|
GrpcServerBuilder |
createBaseRpcServer() |
WebServer |
createWebServer() |
JobMaster |
getJobMaster() |
start, startMasterComponents, stop, stopMasterComponents, toString
createRpcExecutorService, getMaster, getPrimarySelector, getRegistry, getRpcAddress, getRpcBindAddress, getSafeModeManager, getStartTimeMs, getUptimeMs, getWebAddress, getWebBindAddress, isGrpcServing, isMetricSinkServing, isWebServing, registerService, waitForGrpcServerReady, waitForMetricSinkServing, waitForReady, waitForWebServerReady
public WebServer createWebServer()
createWebServer
in class MasterProcess
public GrpcServerBuilder createBaseRpcServer()
createBaseRpcServer
in class MasterProcess
MasterProcess.createRpcExecutorService()
) and the rpc services (provided by MasterProcess.mRegistry
Copyright © 2023. All Rights Reserved.