alluxio.worker

Class AlluxioWorkerProcess

java.lang.Object

alluxio.worker.AlluxioWorkerProcess

All Implemented Interfaces:

Process, WorkerProcess

@NotThreadSafe
public class AlluxioWorkerProcess
extends Object
implements WorkerProcess

This class encapsulates the different worker services that are configured to run.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.worker.WorkerProcess

WorkerProcess.Factory

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AlluxioWorkerProcess(WorkerRegistry workerRegistry, UfsManager ufsManager, Worker worker, DataServerFactory dataServerFactory, NettyDataServer nettyDataServer, HttpServer httpServer, boolean delayWebServer) Creates a new instance of AlluxioWorkerProcess.

Method Summary

Modifier and Type	Method and Description
WorkerNetAddress	getAddress()
String	getDataBindHost()
String	getDataDomainSocketPath()
int	getDataLocalPort()
int	getNettyDataLocalPort()
int	getRestS3LocalPort()
InetSocketAddress	getRpcAddress()
long	getStartTimeMs()
UfsManager	getUfsManager()
long	getUptimeMs()
String	getWebBindHost()
int	getWebLocalPort()
<T extends Worker> T	getWorker(Class<T> clazz)
protected void	setWebServer(WebServer webServer)
void	start() Starts the Alluxio process.
void	stop() Stops the Alluxio process, blocking until the action is completed.
String	toString()
boolean	waitForReady(int timeoutMs) Waits until the process is ready to serve requests.

Methods inherited from class java.lang.Object

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

Constructor Detail

AlluxioWorkerProcess

protected AlluxioWorkerProcess(WorkerRegistry workerRegistry,
                               UfsManager ufsManager,
                               Worker worker,
                               DataServerFactory dataServerFactory,
                               @Nullable
                               NettyDataServer nettyDataServer,
                               @Nullable
                               HttpServer httpServer,
                               boolean delayWebServer)

Creates a new instance of AlluxioWorkerProcess.

Method Detail

setWebServer

protected void setWebServer(WebServer webServer)

getStartTimeMs

public long getStartTimeMs()

Specified by:

getStartTimeMs in interface WorkerProcess

Returns:

the start time of the worker in milliseconds

getUptimeMs

public long getUptimeMs()

Specified by:

getUptimeMs in interface WorkerProcess

Returns:

the uptime of the worker in milliseconds

getDataBindHost

public String getDataBindHost()

Specified by:

getDataBindHost in interface WorkerProcess

Returns:

the worker's data service bind host (used by unit test only)

getDataLocalPort

public int getDataLocalPort()

Specified by:

getDataLocalPort in interface WorkerProcess

Returns:

the worker's data service port (used by unit test only)

getNettyDataLocalPort

public int getNettyDataLocalPort()

Specified by:

getNettyDataLocalPort in interface WorkerProcess

Returns:

the worker's netty data service port (used by unit test only)

getRestS3LocalPort

public int getRestS3LocalPort()

Specified by:

getRestS3LocalPort in interface WorkerProcess

Returns:

the worker's netty s3 data service port (used by unit test only)

getDataDomainSocketPath

public String getDataDomainSocketPath()

Specified by:

getDataDomainSocketPath in interface WorkerProcess

Returns:

the worker's data service domain socket path if available or "" if not available

getWebBindHost

public String getWebBindHost()

Specified by:

getWebBindHost in interface WorkerProcess

Returns:

the worker web service bind host (used by unit test only)

getWebLocalPort

public int getWebLocalPort()

Specified by:

getWebLocalPort in interface WorkerProcess

Returns:

the worker web service port (used by unit test only)

getWorker

public <T extends Worker> T getWorker(Class<T> clazz)

Specified by:

getWorker in interface WorkerProcess

Type Parameters:

T - the type of the worker to get

Parameters:

clazz - the class of the worker to get

Returns:

the given worker

getUfsManager

public UfsManager getUfsManager()

Specified by:

getUfsManager in interface WorkerProcess

Returns:

the block worker for this Alluxio worker

getRpcAddress

public InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in interface WorkerProcess

Returns:

this worker's rpc address

start

public void start()
           throws Exception

Description copied from interface: Process

Starts the Alluxio process. This call blocks until the process is stopped via Process.stop(). The Process.waitForReady(int) method can be used to make sure that the process is ready to serve requests.

Specified by:

start in interface Process

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: Process

Stops the Alluxio process, blocking until the action is completed.

Specified by:

stop in interface Process

Throws:

Exception

waitForReady

public boolean waitForReady(int timeoutMs)

Description copied from interface: Process

Waits until the process is ready to serve requests.

Specified by:

waitForReady in interface Process

Parameters:

timeoutMs - how long to wait in milliseconds

Returns:

whether the process became ready before the specified timeout

getAddress

public WorkerNetAddress getAddress()

Specified by:

getAddress in interface WorkerProcess

Returns:

the connect information for this worker

toString

public String toString()

Overrides:

toString in class Object