@NotThreadSafe public class AlluxioJobMasterProcess extends AlluxioSimpleMasterProcess
Modifier and Type | Field and Description |
---|---|
protected JobMaster |
mJobMaster
The master managing all job related metadata.
|
mGrpcServer, mGrpcServerLock, mJournalSystem, mLeaderSelector, mServingThread, mServingThreadTimeoutMs, mWebServer, mWebServerLock
Modifier and Type | Method and Description |
---|---|
JobMaster |
getJobMaster() |
<T extends Master> |
getMaster(Class<T> clazz)
Gets the registered class from the master registry.
|
getRpcAddress, getWebAddress, start, startMaster, startServing, startServingRPCServer, startServingWebServer, stop, stopMaster, stopServing, toString
getStartTimeMs, getUptimeMs, isGrpcServing, isMetricSinkServing, isWebServing, startRejectingServers, startServing, stopRejectingRpcServer, stopRejectingServers, stopRejectingWebServer, waitForGrpcServerReady, waitForMetricSinkServing, waitForReady, waitForWebServerReady
protected JobMaster mJobMaster
public <T extends Master> T getMaster(Class<T> clazz)
MasterProcess
getMaster
in class MasterProcess
T
- the type of the master to getclazz
- the class of the master to getCopyright © 2023. All Rights Reserved.