ShuffleSchedulerImpl(JobConf, TaskStatus, TaskAttemptID, ExceptionReporter, Progress, Counters.Counter, Counters.Counter, Counters.Counter) |  | 0% | | n/a | 1 | 1 | 34 | 34 | 1 | 1 |
copySucceeded(TaskAttemptID, MapHost, long, long, long, MapOutput) |  | 0% |  | 0% | 4 | 4 | 25 | 25 | 1 | 1 |
copyFailed(TaskAttemptID, MapHost, boolean, boolean) |  | 0% |  | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
updateStatus(String) |  | 0% |  | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
checkReducerHealth() |  | 0% |  | 0% | 9 | 9 | 18 | 18 | 1 | 1 |
getMapsForHost(MapHost) |  | 0% |  | 0% | 9 | 9 | 21 | 21 | 1 | 1 |
resolve(TaskCompletionEvent) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
getHost() |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
getBaseURI(TaskAttemptID, String) |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
freeHost(MapHost) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
addKnownMapOutput(String, String, TaskAttemptID) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
checkAndInformMRAppMaster(int, TaskAttemptID, boolean, boolean, boolean) |  | 0% |  | 0% | 6 | 6 | 4 | 4 | 1 | 1 |
hostFailed(String) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
tipFailed(TaskID) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
reportLocalError(IOException) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
hostFailureCount(String) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
fetchFailureCount(TaskAttemptID) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
waitUntilDone(int) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
penalize(MapHost, long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
resetKnownMaps() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
close() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
obsoleteMapOutput(TaskAttemptID) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
updateStatus() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
putBackKnownMapOutput(MapHost, TaskAttemptID) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getMaxHostFailures() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |