@NotThreadSafe public final class JobWorker extends AbstractWorker
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends Server>> |
getDependencies() |
String |
getName() |
Map<ServiceType,GrpcService> |
getServices() |
void |
start(WorkerNetAddress address)
Starts the Alluxio server.
|
void |
stop()
Stops the Alluxio server.
|
close, getExecutorService
public Set<Class<? extends Server>> getDependencies()
public String getName()
public Map<ServiceType,GrpcService> getServices()
public void start(WorkerNetAddress address) throws IOException
Server
start
in interface Server<WorkerNetAddress>
start
in class AbstractWorker
address
- the start optionsIOException
public void stop() throws IOException
Server
#start(T)
should be
cleaned up and shutdown.stop
in interface Server<WorkerNetAddress>
stop
in class AbstractWorker
IOException
Copyright © 2023. All Rights Reserved.