tachyon
Class Worker

java.lang.Object
  extended by tachyon.Worker
All Implemented Interfaces:
Runnable

public class Worker
extends Object
implements Runnable

Entry point for a worker daemon.


Method Summary
static Worker createWorker(InetSocketAddress masterAddress, InetSocketAddress workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes)
           
static Worker createWorker(String masterAddress, String workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes)
           
static void main(String[] args)
           
 void run()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

run

public void run()
Specified by:
run in interface Runnable

createWorker

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

createWorker

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

start

public void start()

stop

public void stop()
          throws IOException
Throws:
IOException

main

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


Copyright © 2013. All Rights Reserved.