@NotThreadSafe public abstract class AlluxioSimpleMasterProcess extends MasterProcess
mJournalSystem, mLeaderSelector, mRegistry
Modifier and Type | Method and Description |
---|---|
void |
start()
Starts the Alluxio process.
|
protected void |
startMasterComponents(boolean isLeader) |
void |
stop()
Stops the Alluxio master server.
|
protected void |
stopMasterComponents() |
String |
toString() |
createBaseRpcServer, createRpcExecutorService, createWebServer, getMaster, getPrimarySelector, getRegistry, getRpcAddress, getRpcBindAddress, getSafeModeManager, getStartTimeMs, getUptimeMs, getWebAddress, getWebBindAddress, isGrpcServing, isMetricSinkServing, isWebServing, registerService, waitForGrpcServerReady, waitForMetricSinkServing, waitForReady, waitForWebServerReady
public void start() throws Exception
Process
Process.stop()
.
The Process.waitForReady(int)
method can be used to make sure that the process is ready to
serve requests.Exception
public void stop() throws Exception
Exception
- if stopping the master failsprotected void startMasterComponents(boolean isLeader)
protected void stopMasterComponents()
Copyright © 2023. All Rights Reserved.