RMContainerAllocator

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,770 of 1,7700%180 of 1800%1281284634633838
getResources()2380%260%1414646411
scheduleReduces(int, int, int, int, int, int, Resource, Resource, int, float, float)1620%180%1010545411
handleReduceContainerRequest(ContainerRequestEvent)1300%140%88272711
handleMapContainerRequest(ContainerRequestEvent)1090%120%77252511
handleEvent(ContainerAllocatorEvent)1060%140%88313111
handleUpdatedNodes(AllocateResponse)1060%160%99212111
applyConcurrentTaskLimits()980%120%77191911
heartbeat()900%120%77202011
RMContainerAllocator(ClientService, AppContext, AMPreemptionPolicy)890%n/a11252511
serviceInit(Configuration)870%n/a11171711
preemptReducesIfNeeded()610%120%77171711
processFinishedContainer(ContainerStatus)540%20%22121211
preemptReducer(int)480%n/a11171711
static {...}470%20%22121211
handle(ContainerAllocatorEvent)370%60%44111111
getNumHangingRequests(long, Map)370%60%44101011
updateAMRMToken(Token)320%n/a117711
getResourceLimit()270%n/a118811
scheduleAllReduces()200%20%225511
serviceStop()190%40%337711
createContainerFinishedEvent(ContainerStatus, TaskAttemptId)180%20%225511
rampUpReduces(int)170%20%224411
rampDownReduces(int)170%40%338811
getHost(String)160%20%225511
preemptReducersForHangingMapRequests(long)160%20%225511
handleJobPriorityChange(AllocateResponse)150%20%226611
canAssignMaps()140%40%332211
canAssignReduces()140%40%332211
serviceStart()120%n/a114411
createAssignedRequests()50%n/a111111
getNumOfPendingReduces()40%n/a111111
setIsReduceStarted(boolean)40%n/a112211
setReduceResourceRequest(Resource)40%n/a112211
setMapResourceRequest(Resource)40%n/a112211
clearAllPendingReduceRequests()40%n/a112211
getAssignedRequests()30%n/a111111
getScheduledRequests()30%n/a111111
getIsReduceStarted()30%n/a111111