|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Task | |
org.apache.nutch.mapReduce | A system for scalable, fault-tolerant, distributed computation over large data collections. |
Uses of Task in org.apache.nutch.mapReduce |
Subclasses of Task in org.apache.nutch.mapReduce | |
class |
MapTask
A Map task. |
class |
ReduceTask
A Reduce task. |
Methods in org.apache.nutch.mapReduce that return Task | |
Task |
TaskUmbilicalProtocol.getTask(String taskid)
Called when a child task process starts, to get its task. |
Task |
InterTrackerProtocol.pollForNewTask(String trackerName)
Called to get new tasks from from the job tracker for this tracker. |
Task |
JobTracker.JobInProgress.getTask(String taskid)
|
Task |
TaskTracker.getTask(String taskid)
Called upon startup by the child process, to fetch Task data. |
Task |
JobTracker.pollForNewTask(String trackerName)
A tracker wants to know if there's a Task to run |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |