statusUpdate(TaskAttemptID, TaskStatus) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getProtocolVersion(String, long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getProtocolSignature(String, long, int) |  | 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 |
getMapCompletionEvents(JobID, int, int, 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 |
reportNextRecordRange(TaskAttemptID, SortedRanges.Range) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
done(TaskAttemptID) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
commitPending(TaskAttemptID, TaskStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
shuffleError(TaskAttemptID, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
fsError(TaskAttemptID, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
fatalError(TaskAttemptID, String, boolean) |  | 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 |