static {...} |  | 0% | | n/a | 1 | 1 | 111 | 111 | 1 | 1 |
recover(JobHistoryParser.TaskAttemptInfo, OutputCommitter, boolean) |  | 0% |  | 0% | 9 | 9 | 73 | 73 | 1 | 1 |
populateResourceCapability(TaskType) |  | 0% |  | 0% | 15 | 15 | 52 | 52 | 1 | 1 |
TaskAttemptImpl(TaskId, int, EventHandler, TaskAttemptListener, Path, int, JobConf, String[], Token, Credentials, Clock, AppContext) |  | 0% |  | 0% | 2 | 2 | 35 | 35 | 1 | 1 |
logAttemptFinishedEvent(TaskAttemptStateInternal) |  | 0% |  | 0% | 7 | 7 | 25 | 25 | 1 | 1 |
updateMillisCounters(JobCounterUpdateEvent, TaskAttemptImpl) |  | 0% |  | 0% | 5 | 5 | 21 | 21 | 1 | 1 |
handle(TaskAttemptEvent) |  | 0% |  | 0% | 5 | 5 | 23 | 23 | 1 | 1 |
updateProgressSplits() |  | 0% |  | 0% | 9 | 9 | 26 | 26 | 1 | 1 |
createContainerLaunchContext(Map, Configuration, Token, Task, JobID, WrappedJvmID, TaskAttemptListener, Credentials) |  | 0% |  | 0% | 4 | 4 | 23 | 23 | 1 | 1 |
getReport() |  | 0% |  | 0% | 2 | 2 | 19 | 19 | 1 | 1 |
sendLaunchedEvents() |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
configureTokens(Token, Credentials, Map) |  | 0% |  | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
configureJobJar(Configuration, Map) |  | 0% |  | 0% | 3 | 3 | 20 | 20 | 1 | 1 |
createLocalResource(FileSystem, Path, String, LocalResourceType, LocalResourceVisibility) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
createTaskAttemptUnsuccessfulCompletionEvent(TaskAttemptImpl, TaskAttemptStateInternal) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
createCommonContainerLaunchContext(Map, Configuration, Token, JobID, Credentials) |  | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
addExternalShuffleProviders(Configuration, Map) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
computeRackAndLocality() |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
configureEnv(Configuration) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
resolveHosts(String[]) |  | 0% |  | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
notifyTaskAttemptFailed(TaskAttemptImpl, boolean) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
configureJobConf(Configuration, Map, JobID) |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
getInitialClasspath(Configuration) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
sendContainerCleanup(TaskAttemptImpl, TaskAttemptEvent) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
createJobCounterUpdateEventTAFailed(TaskAttemptImpl, boolean) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
createJobCounterUpdateEventTAKilled(TaskAttemptImpl, boolean) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getCpuRequired(Configuration, TaskType) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
sendJHStartEventForAssignedFailTask(TaskAttemptImpl) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
getExternalState(TaskAttemptStateInternal) |  | 0% |  | 0% | 8 | 8 | 9 | 9 | 1 | 1 |
isFinished() |  | 0% |  | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
getProgressSplitBlock() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
sendContainerCompleted(TaskAttemptImpl) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getAssignedContainerMgrAddress() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getDiagnostics() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getResourceTypePrefix(TaskType) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
getCounters() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
initTaskAttemptStatus(TaskAttemptStatusUpdateEvent.TaskAttemptStatus) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getAssignedContainerID() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getNodeId() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getNodeHttpAddress() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
resolveHost(String) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
createJobCounterUpdateEventTASucceeded(TaskAttemptImpl) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getState() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
finalizeProgress(TaskAttemptImpl) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getCpuVcoreDefault(TaskType) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
getInternalState() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getShuffleFinishTime() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getSortFinishTime() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getProgress() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getPhase() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
addDiagnosticInfo(String) |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
getCpuVcoresKey(TaskType) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
getMemoryKey(TaskType) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
getLaunchTime() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getFinishTime() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getShufflePort() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getNodeRackName() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
setFinishTime() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
isContainerAssigned() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getMemoryRequired(JobConf, TaskType) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isIP(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setLocality(Locality) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setAvataar(Avataar) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setTaskFailFast(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setRescheduleNextAttempt(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getID() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLocality() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAvataar() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isTaskFailFast() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRescheduleNextAttempt() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |