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

Modifier and Type	Method and Description
static TachyonWorker	createWorker(InetSocketAddress masterAddress, InetSocketAddress workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes) Create a new TachyonWorker
static TachyonWorker	createWorker(String masterAddress, String workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes) Create a new TachyonWorker
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,
                                         String localFolder,
                                         long spaceLimitBytes)

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

localFolder - This TachyonWorker's local folder's path

spaceLimitBytes - The maximum memory space this TachyonWorker can use, in bytes

Returns:

The new TachyonWorker

createWorker

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

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

localFolder - This TachyonWorker's local folder's path

spaceLimitBytes - The maximum memory space this TachyonWorker can use, in bytes

Returns:

The new TachyonWorker

main

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

Throws:

UnknownHostException

run

public void run()

Specified by:

run in interface Runnable

start

public void start()

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

stop

public void stop()
          throws IOException,
                 InterruptedException

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

Throws:

IOException

InterruptedException