updateConfigIfNeeded() |  | 0% |  | 0% | 6 | 6 | 43 | 43 | 1 | 1 |
containerBasedPreemptOrKill(CSQueue, Resource) |  | 0% |  | 0% | 10 | 10 | 55 | 55 | 1 | 1 |
preemptOrkillSelectedContainerAfterWait(Map, long) |  | 0% |  | 0% | 10 | 10 | 29 | 29 | 1 | 1 |
cloneQueues(CSQueue, Resource, String) |  | 0% |  | 0% | 6 | 6 | 40 | 40 | 1 | 1 |
init(Configuration, RMContext, ResourceScheduler) |  | 0% |  | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
logToCSV(List) |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
syncKillableContainersFromScheduler() |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
getLeafQueueNames(TempQueuePerPartition) |  | 0% |  | 0% | 6 | 6 | 8 | 8 | 1 | 1 |
editSchedule() |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
ProportionalCapacityPreemptionPolicy(RMContext, CapacityScheduler, Clock) |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
ProportionalCapacityPreemptionPolicy() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
addTempQueuePartition(TempQueuePerPartition) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getQueueByPartition(String, String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getQueuePartitions(String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
addPartitionToUnderServedQueues(String, String) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
lambda$cleanupStaledPreemptionCandidates$0(long, Map.Entry) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getPartitionResource(String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
cleanupStaledPreemptionCandidates(long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getUnderServedQueuesPerPartition(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getClusterMaxApplicationPriority() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResourceCalculator() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMonitoringInterval() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getToPreemptContainers() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getScheduler() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRMContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isObserveOnly() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getKillableContainers() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxIgnoreOverCapacity() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNaturalTerminationFactor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLeafQueueNames() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAllPartitions() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueuePartitions() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getToPreemptCandidatesPerSelector() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxAllowableLimitForIntraQueuePreemption() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMinimumThresholdForIntraQueuePreemption() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getIntraQueuePreemptionOrderPolicy() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCrossQueuePreemptionConservativeDRF() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getInQueuePreemptionConservativeDRF() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDefaultMaximumKillWaitTimeout() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPolicyName() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |