assignContainers(Resource, CandidateNodeSet, ResourceLimits, SchedulingMode) |  | 0% |  | 0% | 25 | 25 | 101 | 101 | 1 | 1 |
setupQueueConfigs(Resource) |  | 0% |  | 0% | 8 | 8 | 75 | 75 | 1 | 1 |
activateApplications() |  | 0% |  | 0% | 12 | 12 | 61 | 61 | 1 | 1 |
getUserAMResourceLimitPerPartition(String, String) |  | 0% |  | 0% | 5 | 5 | 34 | 34 | 1 | 1 |
refreshAfterResourceCalculation(Resource, ResourceLimits) |  | 0% |  | 0% | 2 | 2 | 25 | 25 | 1 | 1 |
releaseResource(Resource, FiCaSchedulerApp, Resource, String, RMContainer) |  | 0% |  | 0% | 8 | 8 | 26 | 26 | 1 | 1 |
removeApplicationAttempt(FiCaSchedulerApp, String) |  | 0% |  | 0% | 5 | 5 | 31 | 31 | 1 | 1 |
allocateResource(Resource, SchedulerApplicationAttempt, Resource, String, RMContainer) |  | 0% |  | 0% | 6 | 6 | 22 | 22 | 1 | 1 |
calculateAndGetAMResourceLimitPerPartition(String) |  | 0% |  | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
getTotalPendingResourcesConsideringUserLimit(Resource, String, boolean) |  | 0% |  | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
updateMaximumApplications(boolean) |  | 0% |  | 0% | 8 | 8 | 27 | 27 | 1 | 1 |
canAssignToUser(Resource, String, Resource, FiCaSchedulerApp, String, ResourceLimits) |  | 0% |  | 0% | 7 | 7 | 26 | 26 | 1 | 1 |
validateSubmitApplication(ApplicationId, String, String) |  | 0% |  | 0% | 6 | 6 | 24 | 24 | 1 | 1 |
completedContainer(Resource, FiCaSchedulerApp, FiCaSchedulerNode, RMContainer, ContainerStatus, RMContainerEventType, CSQueue, boolean) |  | 0% |  | 0% | 7 | 7 | 24 | 24 | 1 | 1 |
addApplicationAttempt(FiCaSchedulerApp, UsersManager.User) |  | 0% |  | 0% | 3 | 3 | 30 | 30 | 1 | 1 |
AbstractLeafQueue(CapacitySchedulerQueueContext, String, CSQueue, CSQueue, boolean) |  | 0% | | n/a | 1 | 1 | 19 | 19 | 1 | 1 |
getUserLimitCache(String, SchedulingMode) |  | 0% |  | 0% | 4 | 4 | 20 | 20 | 1 | 1 |
computeUserLimitAndSetHeadroom(FiCaSchedulerApp, Resource, String, SchedulingMode, Resource) |  | 0% |  | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
accept(Resource, ResourceCommitRequest) |  | 0% |  | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
updateClusterResourceLegacyMode(Resource, ResourceLimits) |  | 0% |  | 0% | 2 | 2 | 19 | 19 | 1 | 1 |
apply(Resource, ResourceCommitRequest) |  | 0% |  | 0% | 6 | 6 | 24 | 24 | 1 | 1 |
releaseContainers(Resource, ResourceCommitRequest) |  | 0% |  | 0% | 7 | 7 | 15 | 15 | 1 | 1 |
reinitialize(CSQueue, Resource) |  | 0% |  | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
getHeadroom(UsersManager.User, Resource, Resource, Resource, String) |  | 0% |  | 0% | 2 | 2 | 18 | 18 | 1 | 1 |
getQueueUserAclInfo(UserGroupInformation) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
internalReleaseContainer(Resource, SchedulerContainer) |  | 0% |  | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
attachContainer(Resource, FiCaSchedulerApp, RMContainer) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
detachContainer(Resource, FiCaSchedulerApp, RMContainer) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
updateQueuePreemptionMetrics(RMContainer) |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
submitApplicationAttempt(FiCaSchedulerApp, String, boolean) |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
setPreemptionAllowed(ResourceLimits, String) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
collectSchedulerApplications(Collection) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
recoverContainer(Resource, SchedulerApplicationAttempt, RMContainer) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
recalculateQueueUsageRatio(Resource, String) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
getIgnoreExclusivityRMContainers() |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
allocateFromReservedContainer(Resource, CandidateNodeSet, ResourceLimits, SchedulingMode) |  | 0% |  | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
updateSchedulerHealthForCompletedContainer(RMContainer, ContainerStatus) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
updateApplicationPriority(SchedulerApplication, Priority) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
updateMaxAppsPerUser() |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
setDynamicQueueACLProperties() |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
submitApplication(ApplicationId, String, String) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
updateCurrentResourceLimits(ResourceLimits, Resource) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getNumPendingApplications(String) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getNumActiveApplications(String) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
updateClusterResource(Resource, ResourceLimits) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
incAMUsedResource(String, Resource, SchedulerApplicationAttempt) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
decAMUsedResource(String, Resource, SchedulerApplicationAttempt) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getExtendedCapacityOrWeightString() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
setQueueResourceLimitsInfo(Resource) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
setOrderingPolicy(OrderingPolicy) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
incUsedResource(String, Resource, SchedulerApplicationAttempt) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
decUsedResource(String, Resource, SchedulerApplicationAttempt) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getNumApplications() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
parseAndSetDynamicTemplates() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
setCapacity(String, float) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
stopQueue() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getCopyOfNonRunnableAppSchedulables() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
isEligibleForAutoDeletion() |  | 0% |  | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
getAllApplications() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
setCapacity(float) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getPriorityACLs() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getHeadroom(UsersManager.User, Resource, Resource, FiCaSchedulerApp, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
finishApplication(ApplicationId, String) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
removeNonRunnableApp(FiCaSchedulerApp) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getNumPendingApplications() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getNumActiveApplications() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getNumRunnableApps() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getNumNonRunnableApps() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
finishApplicationAttempt(FiCaSchedulerApp, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getDefaultNodeLabelExpressionStr() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
lambda$refreshAfterResourceCalculation$2(Long) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
AbstractLeafQueue(CapacitySchedulerQueueContext, String, CSQueue, CSQueue) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setUserLimit(float) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
setUserLimitFactor(float) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getHeadroom(UsersManager.User, Resource, Resource, FiCaSchedulerApp) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResourceLimitForActiveUsers(String, Resource, String, SchedulingMode) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResourceLimitForAllUsers(String, Resource, String, SchedulingMode) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
submitApplicationAttempt(FiCaSchedulerApp, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAMResourceLimitPerPartition(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getApplication(ApplicationAttemptId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setAbsoluteCapacity(String, float) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getQueueInfo(boolean, boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getUser(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOrCreateUser(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAMResourceLimit() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUserAMResourceLimit() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingApplications() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getApplications() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setAbsoluteCapacity(float) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAllUsers() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUserLimit() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUserLimitFactor() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
calculateAndGetAMResourceLimit() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setMaxApplicationsPerUser(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMaxApplications(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setMaxAMResourcePerQueuePercent(float) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$allocateResource$1(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$assignContainers$0(FiCaSchedulerApp) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getMinimumAllocationFactor() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxAMResourcePerQueuePercent() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxApplications() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxApplicationsPerUser() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUsersManager() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAbstractUsersManager() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNodeLocalityDelay() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRackLocalityAdditionalDelay() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRackLocalityFullReset() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOrderingPolicy() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDefaultApplicationPriority() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingAppsOrderingPolicy() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getChildQueues() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getChildQueuesByTryLock() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |