cgl.imr.worker
Class Mapper

java.lang.Object
  extended by cgl.imr.worker.Mapper
All Implemented Interfaces:
Runnable

public class Mapper
extends Object
implements Runnable

Executor for the map tasks. Executor holds the map task configuration and the DaemonWorker schedules them for execution depending on the requests from the TwisterDriver.


Constructor Summary
Mapper(MapperRequest mapperRequest, PubSubService pubsubService, CustomClassLoader classLoader)
           
 
Method Summary
 void close()
           
 MapTaskRequest getCurrentRequest()
           
 Exception getException()
           
 boolean isHasException()
           
 void run()
           
 void setCurrentRequest(MapTaskRequest currentRequest)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Mapper

public Mapper(MapperRequest mapperRequest,
              PubSubService pubsubService,
              CustomClassLoader classLoader)
       throws TwisterException
Throws:
TwisterException
Method Detail

close

public void close()
           throws TwisterException
Throws:
TwisterException

getCurrentRequest

public MapTaskRequest getCurrentRequest()

getException

public Exception getException()

isHasException

public boolean isHasException()

run

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

setCurrentRequest

public void setCurrentRequest(MapTaskRequest currentRequest)


For comments and suggestions please send e-mail to