|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MapOutputLocation | |
org.apache.nutch.mapReduce | A system for scalable, fault-tolerant, distributed computation over large data collections. |
Uses of MapOutputLocation in org.apache.nutch.mapReduce |
Methods in org.apache.nutch.mapReduce that return MapOutputLocation | |
MapOutputLocation[] |
InterTrackerProtocol.locateMapOutputs(String taskId,
String[] mapTasksNeeded)
Called by a reduce task to find which map tasks are completed. |
MapOutputLocation[] |
JobTracker.JobInProgress.locateTasks(String[] taskIds)
Return locations for all the indicated taskIds. |
MapOutputLocation[] |
JobTracker.locateMapOutputs(String taskId,
String[] mapTasksNeeded)
A tracker wants to know the physical locations of completed, but not yet closed, tasks. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |