getResources() |  | 0% |  | 0% | 14 | 14 | 64 | 64 | 1 | 1 |
scheduleReduces(int, int, int, int, int, int, Resource, Resource, int, float, float) |  | 0% |  | 0% | 10 | 10 | 54 | 54 | 1 | 1 |
handleReduceContainerRequest(ContainerRequestEvent) |  | 0% |  | 0% | 8 | 8 | 27 | 27 | 1 | 1 |
handleMapContainerRequest(ContainerRequestEvent) |  | 0% |  | 0% | 7 | 7 | 25 | 25 | 1 | 1 |
handleEvent(ContainerAllocatorEvent) |  | 0% |  | 0% | 8 | 8 | 31 | 31 | 1 | 1 |
handleUpdatedNodes(AllocateResponse) |  | 0% |  | 0% | 9 | 9 | 21 | 21 | 1 | 1 |
applyConcurrentTaskLimits() |  | 0% |  | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
heartbeat() |  | 0% |  | 0% | 7 | 7 | 20 | 20 | 1 | 1 |
RMContainerAllocator(ClientService, AppContext, AMPreemptionPolicy) |  | 0% | | n/a | 1 | 1 | 25 | 25 | 1 | 1 |
serviceInit(Configuration) |  | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
preemptReducesIfNeeded() |  | 0% |  | 0% | 7 | 7 | 17 | 17 | 1 | 1 |
processFinishedContainer(ContainerStatus) |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
preemptReducer(int) |  | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
handle(ContainerAllocatorEvent) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
getNumHangingRequests(long, Map) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
updateAMRMToken(Token) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getResourceLimit() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
scheduleAllReduces() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
serviceStop() |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
createContainerFinishedEvent(ContainerStatus, TaskAttemptId) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
rampUpReduces(int) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
rampDownReduces(int) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getHost(String) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
preemptReducersForHangingMapRequests(long) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
handleJobPriorityChange(AllocateResponse) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
canAssignMaps() |  | 0% |  | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
canAssignReduces() |  | 0% |  | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
serviceStart() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createAssignedRequests() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumOfPendingReduces() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setIsReduceStarted(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setReduceResourceRequest(Resource) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMapResourceRequest(Resource) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
clearAllPendingReduceRequests() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAssignedRequests() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getScheduledRequests() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getIsReduceStarted() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |