alluxio.worker.file

Class DefaultFileSystemWorker

java.lang.Object

alluxio.worker.AbstractWorker

alluxio.worker.file.DefaultFileSystemWorker

All Implemented Interfaces:

Server<WorkerNetAddress>, FileSystemWorker, Worker

@NotThreadSafe
public final class DefaultFileSystemWorker
extends AbstractWorker
implements FileSystemWorker

This class is responsible for persisting files when requested by the master and a defunct FileSystemWorkerClientServiceHandler which always returns UnsupportedOperation Exception.

Method Summary

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.

Methods inherited from class alluxio.worker.AbstractWorker

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()

Specified by:

getDependencies in interface Server<WorkerNetAddress>

Returns:

the server dependencies

getName

public String getName()

Specified by:

getName in interface Server<WorkerNetAddress>

Returns:

the server's name

getServices

public Map<String,org.apache.thrift.TProcessor> getServices()

Specified by:

getServices in interface Server<WorkerNetAddress>

Returns:

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

start

public void start(WorkerNetAddress address)

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<WorkerNetAddress>

Parameters:

address - the start options

stop

public void stop()

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>