tachyon.worker

Class TachyonWorker

java.lang.Object

tachyon.worker.TachyonWorker

All Implemented Interfaces:

Runnable

public class TachyonWorker
extends Object
implements Runnable

Entry point for a worker daemon.

Method Summary

Methods

Modifier and Type	Method and Description
static TachyonWorker	createWorker(InetSocketAddress masterAddress, InetSocketAddress workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads) Create a new TachyonWorker
static TachyonWorker	createWorker(String masterAddress, String workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads) Create a new TachyonWorker
int	getDataPort() Gets the data port of the worker.
int	getMetaPort() Gets the metadata port of the worker.
static void	main(String[] args)
void	run()
void	start() Start the data server thread and heartbeat thread of this TachyonWorker.
void	stop() Stop this TachyonWorker.

Methods inherited from class java.lang.Object

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

Method Detail

createWorker

public static TachyonWorker createWorker(InetSocketAddress masterAddress,
                         InetSocketAddress workerAddress,
                         int dataPort,
                         int selectorThreads,
                         int acceptQueueSizePerThreads,
                         int workerThreads)

Create a new TachyonWorker

Parameters:

masterAddress - The TachyonMaster's address

workerAddress - This TachyonWorker's address

dataPort - This TachyonWorker's data server's port

selectorThreads - The number of selector threads of the worker's thrift server

acceptQueueSizePerThreads - The accept queue size per thread of the worker's thrift server

workerThreads - The number of threads of the worker's thrift server

Returns:

The new TachyonWorker

createWorker

public static TachyonWorker createWorker(String masterAddress,
                         String workerAddress,
                         int dataPort,
                         int selectorThreads,
                         int acceptQueueSizePerThreads,
                         int workerThreads)

Create a new TachyonWorker

Parameters:

masterAddress - The TachyonMaster's address. e.g., localhost:19998

workerAddress - This TachyonWorker's address. e.g., localhost:29998

dataPort - This TachyonWorker's data server's port

selectorThreads - The number of selector threads of the worker's thrift server

acceptQueueSizePerThreads - The accept queue size per thread of the worker's thrift server

workerThreads - The number of threads of the worker's thrift server

Returns:

The new TachyonWorker

main

public static void main(String[] args)
                 throws UnknownHostException

Throws:

UnknownHostException

getDataPort

public int getDataPort()

Gets the data port of the worker. For unit tests only.

getMetaPort

public int getMetaPort()

Gets the metadata port of the worker. For unit tests only.

run

public void run()

Specified by:

run in interface Runnable

start

public void start()
           throws IOException

Start the data server thread and heartbeat thread of this TachyonWorker.

Throws:

IOException

stop

public void stop()
          throws IOException,
                 InterruptedException

Stop this TachyonWorker. Stop all the threads belong to this TachyonWorker.

Throws:

IOException

InterruptedException