cgl.imr.worker
Class TwisterDaemon

java.lang.Object
  extended by cgl.imr.worker.TwisterDaemon

public class TwisterDaemon
extends Object

TwisterDaemon that is responsible for all the server side processing in Twister framework. Once started, every daemon starts listening to a given port which can be used to stop the daemons from running at the end of the MapReduce computations or abruptly in the middle of a computation. This method has no relation to the pub-sub broker communications and hence can be used even in the case of pub-sub broker failures.


Constructor Summary
TwisterDaemon(int daemonNo, int numMapWorkers)
           
 
Method Summary
static void main(String[] args)
           
 void run()
          Handles the socket based communication, which is use to stop the TwisterDaemon.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TwisterDaemon

public TwisterDaemon(int daemonNo,
                     int numMapWorkers)
Method Detail

main

public static void main(String[] args)

run

public void run()
Handles the socket based communication, which is use to stop the TwisterDaemon.



For comments and suggestions please send e-mail to