AbstractLeafQueue

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total4,279 of 4,2790%334 of 3340%2812811,1011,101114114
assignContainers(Resource, CandidateNodeSet, ResourceLimits, SchedulingMode)3910%480%252510110111
setupQueueConfigs(Resource)2820%140%88757511
activateApplications()2740%220%1212616111
getUserAMResourceLimitPerPartition(String, String)1700%80%55343411
refreshAfterResourceCalculation(Resource, ResourceLimits)1160%20%22252511
releaseResource(Resource, FiCaSchedulerApp, Resource, String, RMContainer)1110%140%88262611
removeApplicationAttempt(FiCaSchedulerApp, String)1060%80%55313111
allocateResource(Resource, SchedulerApplicationAttempt, Resource, String, RMContainer)1020%100%66222211
calculateAndGetAMResourceLimitPerPartition(String)990%40%33181811
getTotalPendingResourcesConsideringUserLimit(Resource, String, boolean)990%60%44242411
updateMaximumApplications(boolean)960%140%88272711
canAssignToUser(Resource, String, Resource, FiCaSchedulerApp, String, ResourceLimits)940%120%77262611
validateSubmitApplication(ApplicationId, String, String)930%100%66242411
completedContainer(Resource, FiCaSchedulerApp, FiCaSchedulerNode, RMContainer, ContainerStatus, RMContainerEventType, CSQueue, boolean)930%120%77242411
addApplicationAttempt(FiCaSchedulerApp, UsersManager.User)860%40%33303011
AbstractLeafQueue(CapacitySchedulerQueueContext, String, CSQueue, CSQueue, boolean)820%n/a11191911
getUserLimitCache(String, SchedulingMode)810%60%44202011
computeUserLimitAndSetHeadroom(FiCaSchedulerApp, Resource, String, SchedulingMode, Resource)810%80%55181811
accept(Resource, ResourceCommitRequest)790%60%44242411
updateClusterResourceLegacyMode(Resource, ResourceLimits)730%20%22191911
apply(Resource, ResourceCommitRequest)700%100%66242411
releaseContainers(Resource, ResourceCommitRequest)570%120%77151511
reinitialize(CSQueue, Resource)560%80%55161611
getHeadroom(UsersManager.User, Resource, Resource, Resource, String)550%20%22181811
getQueueUserAclInfo(UserGroupInformation)530%40%33101011
internalReleaseContainer(Resource, SchedulerContainer)520%40%33151511
attachContainer(Resource, FiCaSchedulerApp, RMContainer)520%60%44141411
detachContainer(Resource, FiCaSchedulerApp, RMContainer)520%60%44141411
updateQueuePreemptionMetrics(RMContainer)510%n/a11131311
submitApplicationAttempt(FiCaSchedulerApp, String, boolean)480%80%55121211
setPreemptionAllowed(ResourceLimits, String)470%40%33101011
collectSchedulerApplications(Collection)430%40%33101011
recoverContainer(Resource, SchedulerApplicationAttempt, RMContainer)410%40%33121211
recalculateQueueUsageRatio(Resource, String)390%40%33111111
getIgnoreExclusivityRMContainers()390%20%228811
allocateFromReservedContainer(Resource, CandidateNodeSet, ResourceLimits, SchedulingMode)380%60%44121211
updateSchedulerHealthForCompletedContainer(RMContainer, ContainerStatus)370%40%33111111
updateApplicationPriority(SchedulerApplication, Priority)370%40%33111111
toString()350%n/a11101011
updateMaxAppsPerUser()330%20%228811
setDynamicQueueACLProperties()300%40%338811
submitApplication(ApplicationId, String, String)250%n/a119911
updateCurrentResourceLimits(ResourceLimits, Resource)250%n/a117711
getNumPendingApplications(String)220%20%226611
getNumActiveApplications(String)220%20%226611
updateClusterResource(Resource, ResourceLimits)200%20%226611
incAMUsedResource(String, Resource, SchedulerApplicationAttempt)200%20%226611
decAMUsedResource(String, Resource, SchedulerApplicationAttempt)200%20%226611
getExtendedCapacityOrWeightString()190%20%224411
setQueueResourceLimitsInfo(Resource)190%n/a116611
setOrderingPolicy(OrderingPolicy)190%20%227711
incUsedResource(String, Resource, SchedulerApplicationAttempt)180%n/a114411
decUsedResource(String, Resource, SchedulerApplicationAttempt)180%n/a114411
getNumApplications()170%n/a114411
parseAndSetDynamicTemplates()170%n/a115511
setCapacity(String, float)170%n/a113311
stopQueue()170%20%226611
getCopyOfNonRunnableAppSchedulables()170%n/a115511
isEligibleForAutoDeletion()170%60%443311
getAllApplications()160%n/a114411
setCapacity(float)160%n/a113311
getPriorityACLs()140%n/a113311
getHeadroom(UsersManager.User, Resource, Resource, FiCaSchedulerApp, String)140%n/a112211
finishApplication(ApplicationId, String)130%n/a114411
removeNonRunnableApp(FiCaSchedulerApp)130%n/a113311
getNumPendingApplications()120%n/a113311
getNumActiveApplications()120%n/a113311
getNumRunnableApps()120%n/a113311
getNumNonRunnableApps()120%n/a113311
finishApplicationAttempt(FiCaSchedulerApp, String)110%n/a113311
getDefaultNodeLabelExpressionStr()100%20%222211
lambda$refreshAfterResourceCalculation$2(Long)90%20%221111
AbstractLeafQueue(CapacitySchedulerQueueContext, String, CSQueue, CSQueue)80%n/a112211
setUserLimit(float)80%n/a113311
setUserLimitFactor(float)80%n/a113311
getHeadroom(UsersManager.User, Resource, Resource, FiCaSchedulerApp)80%n/a111111
getResourceLimitForActiveUsers(String, Resource, String, SchedulingMode)80%n/a111111
getResourceLimitForAllUsers(String, Resource, String, SchedulingMode)80%n/a111111
submitApplicationAttempt(FiCaSchedulerApp, String)60%n/a112211
getAMResourceLimitPerPartition(String)60%n/a111111
getApplication(ApplicationAttemptId)60%n/a111111
setAbsoluteCapacity(String, float)60%n/a112211
getQueueInfo(boolean, boolean)50%n/a112211
getUser(String)50%n/a111111
getOrCreateUser(String)50%n/a111111
getAMResourceLimit()50%n/a111111
getUserAMResourceLimit()50%n/a111111
getPendingApplications()50%n/a112211
getApplications()50%n/a112211
setAbsoluteCapacity(float)50%n/a112211
getAllUsers()50%n/a111111
getUserLimit()40%n/a111111
getUserLimitFactor()40%n/a111111
calculateAndGetAMResourceLimit()40%n/a111111
setMaxApplicationsPerUser(int)40%n/a112211
setMaxApplications(int)40%n/a112211
setMaxAMResourcePerQueuePercent(float)40%n/a112211
lambda$allocateResource$1(String)40%n/a111111
lambda$assignContainers$0(FiCaSchedulerApp)40%n/a112211
static {...}40%n/a112211
getMinimumAllocationFactor()0%n/a111111
getMaxAMResourcePerQueuePercent()0%n/a111111
getMaxApplications()0%n/a111111
getMaxApplicationsPerUser()0%n/a111111
getUsersManager()0%n/a111111
getAbstractUsersManager()0%n/a111111
getNodeLocalityDelay()0%n/a111111
getRackLocalityAdditionalDelay()0%n/a111111
getRackLocalityFullReset()0%n/a111111
getOrderingPolicy()0%n/a111111
getDefaultApplicationPriority()0%n/a111111
getPendingAppsOrderingPolicy()0%n/a111111
getChildQueues()0%n/a111111
getChildQueuesByTryLock()0%n/a111111