@ThreadSafe public final class KeyValueWorker extends AbstractWorker
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends Server>> |
getDependencies() |
String |
getName() |
Map<String,org.apache.thrift.TProcessor> |
getServices() |
void |
start(WorkerNetAddress address)
Starts the Alluxio server.
|
void |
stop()
Stops the Alluxio server.
|
getExecutorService
public Set<Class<? extends Server>> getDependencies()
public String getName()
public Map<String,org.apache.thrift.TProcessor> getServices()
TProcessor
s that serve RPCs for this serverpublic void start(WorkerNetAddress address)
Server
address
- the start optionspublic void stop() throws IOException
Server
#start(T)
should be
cleaned up and shutdown.IOException
Copyright © 2023. All Rights Reserved.