|
|||||||||||
| 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 | ||||||||||