@NotThreadSafe public class AlluxioJobMasterProcess extends MasterProcess
Modifier and Type | Field and Description |
---|---|
protected JobMaster |
mJobMaster
The master managing all job related metadata.
|
mGrpcServer, mJournalSystem, mWebServer
Modifier and Type | Method and Description |
---|---|
JobMaster |
getJobMaster() |
<T extends Master> |
getMaster(Class<T> clazz)
Gets the registered class from the master registry.
|
InetSocketAddress |
getRpcAddress() |
InetSocketAddress |
getWebAddress() |
void |
start()
Starts the Alluxio job master server.
|
protected void |
startMaster(boolean isLeader) |
protected void |
startServing(String startMessage,
String stopMessage) |
protected void |
startServingRPCServer()
Starts the gRPC server.
|
protected void |
startServingWebServer() |
void |
stop()
Stops the Alluxio job master server.
|
protected void |
stopMaster() |
protected void |
stopServing() |
String |
toString() |
getStartTimeMs, getUptimeMs, isServing, startRejectingServers, startServing, stopRejectingRpcServer, stopRejectingServers, stopRejectingWebServer, waitForReady
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 get@Nullable public InetSocketAddress getWebAddress()
getWebAddress
in class MasterProcess
public InetSocketAddress getRpcAddress()
getRpcAddress
in class MasterProcess
public void start() throws Exception
Exception
- if starting the master failspublic void stop() throws Exception
Exception
- if stopping the master failsprotected void startMaster(boolean isLeader)
protected void stopMaster()
protected void startServingWebServer()
protected void startServingRPCServer()
Master
s and meta services.Copyright © 2023. All Rights Reserved.