alluxio.worker

Class AbstractWorker

java.lang.Object

alluxio.worker.AbstractWorker

All Implemented Interfaces:

Server<WorkerNetAddress>, Worker

Direct Known Subclasses:

DefaultBlockWorker, DefaultFileSystemWorker, JobWorker

@NotThreadSafe
public abstract class AbstractWorker
extends Object
implements Worker

This is the base class for all workers, and contains common functionality.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractWorker(ExecutorService executorService)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the server.
protected ExecutorService	getExecutorService()

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.Server

getDependencies, getName, getServices, start, stop

Constructor Detail

AbstractWorker

protected AbstractWorker(ExecutorService executorService)

Parameters:

executorService - executor service to use internally

Method Detail

getExecutorService

protected ExecutorService getExecutorService()

Returns:

the executor service

close

public void close()
           throws IOException

Description copied from interface: Server

Closes the server.

Specified by:

close in interface Server<WorkerNetAddress>

Throws:

IOException