run() |  | 0% |  | 0% | 5 | 5 | 50 | 50 | 1 | 1 |
LocalJobRunner.Job(LocalJobRunner, JobID, String) |  | 0% |  | 0% | 3 | 3 | 40 | 40 | 1 | 1 |
statusUpdate(TaskAttemptID, TaskStatus) |  | 0% |  | 0% | 5 | 5 | 31 | 31 | 1 | 1 |
runTasks(List, ExecutorService, String) |  | 0% |  | 0% | 4 | 4 | 16 | 16 | 1 | 1 |
createOutputCommitter(boolean, JobID, Configuration) |  | 0% |  | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
getCurrentCounters() |  | 0% |  | 0% | 6 | 6 | 9 | 9 | 1 | 1 |
createMapExecutor() |  | 0% |  | 0% | 2 | 2 | 13 | 13 | 1 | 1 |
createReduceExecutor() |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
initCounters(int, int) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
getMapTaskRunnables(JobSplit.TaskSplitMetaInfo[], JobID, Map) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
getReduceTaskRunnables(JobID, Map) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
fatalError(TaskAttemptID, String, boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
done(TaskAttemptID) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
reportNextRecordRange(TaskAttemptID, SortedRanges.Range) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
fsError(TaskAttemptID, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
shuffleError(TaskAttemptID, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getProtocolSignature(String, long, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
commitPending(TaskAttemptID, TaskStatus) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getMapCompletionEvents(JobID, int, int, TaskAttemptID) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getProtocolVersion(String, long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTask(JvmContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
canCommit(TaskAttemptID) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCheckpointID(TaskID) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
reportDiagnosticInfo(TaskAttemptID, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
preempted(TaskAttemptID, TaskStatus) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setCheckpointID(TaskID, TaskCheckpointID) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |