alluxio.worker

Class JobWorker

java.lang.Object

alluxio.worker.AbstractWorker

alluxio.worker.JobWorker

All Implemented Interfaces:

Server<WorkerNetAddress>, Worker

@NotThreadSafe
public final class JobWorker
extends AbstractWorker

A job worker that manages all the worker-related activities.

Method Summary

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.

Methods inherited from class alluxio.worker.AbstractWorker

close, getExecutorService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getDependencies

public Set<Class<? extends Server>> getDependencies()

Returns:

the server dependencies

getName

public String getName()

Returns:

the server's name

getServices

public Map<ServiceType,GrpcService> getServices()

Returns:

a map from service names to gRPC serviced that serve RPCs for this server

start

public void start(WorkerNetAddress address)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<WorkerNetAddress>

Overrides:

start in class AbstractWorker

Parameters:

address - the start options

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: Server

Stops the Alluxio server. Here, anything created or started in #start(T) should be cleaned up and shutdown.

Specified by:

stop in interface Server<WorkerNetAddress>

Overrides:

stop in class AbstractWorker

Throws:

IOException