@NotThreadSafe public abstract class AbstractWorker extends Object implements Worker
Modifier | Constructor and Description |
---|---|
protected |
AbstractWorker(ExecutorServiceFactory executorServiceFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the server.
|
protected ExecutorService |
getExecutorService() |
void |
start(WorkerNetAddress address)
Starts the Alluxio server.
|
void |
stop()
Stops the Alluxio server.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDependencies, getName, getServices
protected AbstractWorker(ExecutorServiceFactory executorServiceFactory)
executorServiceFactory
- executor service factory to use internallyprotected ExecutorService getExecutorService()
public void start(WorkerNetAddress address) throws IOException
Server
start
in interface Server<WorkerNetAddress>
address
- the start optionsIOException
public void stop() throws IOException
Server
#start(T)
should be
cleaned up and shutdown.stop
in interface Server<WorkerNetAddress>
IOException
public void close() throws IOException
Server
close
in interface Server<WorkerNetAddress>
IOException
Copyright © 2023. All Rights Reserved.