Searched refs:scheduledRequests (Results 1 – 2 of 2) sorted by relevance
253 scheduledRequests.assign(allocatedContainers); in heartbeat()259 (scheduledRequests.maps.size() > 0)) { in heartbeat()268 scheduledRequests.maps.size(), scheduledRequests.reduces.size(), in heartbeat()301 return scheduledRequests; in getScheduledRequests()407 boolean removed = scheduledRequests.remove(aId); in handleEvent()459 if (scheduledRequests.maps.size() > 0) { in preemptReducesIfNeeded()474 + scheduledRequests.reduces.size()); in preemptReducesIfNeeded()478 scheduledRequests.reduces.clear(); in preemptReducesIfNeeded()638 scheduledRequests.addReduce(req); in scheduleAllReduces()648 scheduledRequests.addReduce(request); in rampUpReduces()[all …]
488 RMContainerAllocator.ScheduledRequests scheduledRequests = in testPreemptReducers() local492 scheduledRequests.maps.put(mock(TaskAttemptId.class), in testPreemptReducers()543 RMContainerAllocator.ScheduledRequests scheduledRequests = in testNonAggressivelyPreemptReducers() local547 scheduledRequests.maps.put(mock(TaskAttemptId.class), in testNonAggressivelyPreemptReducers()