handle(SchedulerEvent) |  | 0% |  | 0% | 23 | 23 | 104 | 104 | 1 | 1 |
addApplication(ApplicationId, String, String, Priority, ApplicationPlacementContext, boolean) |  | 0% |  | 0% | 10 | 10 | 53 | 53 | 1 | 1 |
createResourceCommitRequest(CSAssignment) |  | 0% |  | 0% | 17 | 17 | 56 | 56 | 1 | 1 |
schedule(CapacityScheduler) |  | 0% |  | 0% | 18 | 18 | 52 | 52 | 1 | 1 |
moveApplication(ApplicationId, String) |  | 0% |  | 0% | 7 | 7 | 38 | 38 | 1 | 1 |
allocate(ApplicationAttemptId, List, List, List, List, List, ContainerUpdates) |  | 0% |  | 0% | 13 | 13 | 39 | 39 | 1 | 1 |
initScheduler(Configuration) |  | 0% | | n/a | 1 | 1 | 29 | 29 | 1 | 1 |
addApplicationOnRecovery(ApplicationId, String, String, Priority, ApplicationPlacementContext, boolean) |  | 0% |  | 0% | 6 | 6 | 29 | 29 | 1 | 1 |
doneApplicationAttempt(ApplicationAttemptId, RMAppAttemptState, boolean) |  | 0% |  | 0% | 9 | 9 | 31 | 31 | 1 | 1 |
allocateFromReservedContainer(FiCaSchedulerNode, boolean, RMContainer) |  | 0% |  | 0% | 6 | 6 | 32 | 32 | 1 | 1 |
checkAndGetApplicationLifetime(String, long, RMAppImpl) |  | 0% |  | 0% | 9 | 9 | 32 | 32 | 1 | 1 |
reinitialize(Configuration, RMContext, boolean) |  | 0% |  | 0% | 3 | 3 | 30 | 30 | 1 | 1 |
allocateOrReserveNewContainers(CandidateNodeSet, boolean) |  | 0% |  | 0% | 6 | 6 | 31 | 31 | 1 | 1 |
updateApplicationPriority(Priority, ApplicationId, SettableFuture, UserGroupInformation) |  | 0% |  | 0% | 3 | 3 | 27 | 27 | 1 | 1 |
tryCommit(Resource, ResourceCommitRequest, boolean) |  | 0% |  | 0% | 11 | 11 | 35 | 35 | 1 | 1 |
updateSchedulerHealth(long, NodeId, CSAssignment) |  | 0% |  | 0% | 4 | 4 | 25 | 25 | 1 | 1 |
removeNode(RMNode) |  | 0% |  | 0% | 5 | 5 | 29 | 29 | 1 | 1 |
resolveReservationQueueName(String, ApplicationId, ReservationId, boolean) |  | 0% |  | 0% | 8 | 8 | 23 | 23 | 1 | 1 |
createResourceCommitRequest(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode) |  | 0% |  | 0% | 4 | 4 | 26 | 26 | 1 | 1 |
updatePlacementRules() |  | 0% |  | 0% | 8 | 8 | 30 | 30 | 1 | 1 |
addApplicationAttempt(ApplicationAttemptId, boolean, boolean) |  | 0% |  | 0% | 4 | 4 | 26 | 26 | 1 | 1 |
allocateContainerOnSingleNode(CandidateNodeSet, FiCaSchedulerNode, boolean) |  | 0% |  | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
allocateContainersToNode(NodeId, boolean) |  | 0% |  | 0% | 12 | 12 | 26 | 26 | 1 | 1 |
addNode(RMNode) |  | 0% |  | 0% | 6 | 6 | 20 | 20 | 1 | 1 |
getOrCreateQueueFromPlacementContext(ApplicationId, String, String, ApplicationPlacementContext, boolean) |  | 0% |  | 0% | 7 | 7 | 23 | 23 | 1 | 1 |
checkAndGetApplicationPriority(Priority, UserGroupInformation, String, ApplicationId) |  | 0% |  | 0% | 5 | 5 | 19 | 19 | 1 | 1 |
moveReservedContainer(RMContainer, FiCaSchedulerNode) |  | 0% |  | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
preValidateMoveApplication(ApplicationId, String) |  | 0% |  | 0% | 4 | 4 | 22 | 22 | 1 | 1 |
updateLabelsOnNode(NodeId, Set) |  | 0% |  | 0% | 6 | 6 | 22 | 22 | 1 | 1 |
allocateContainersToNode(CandidateNodeSet, boolean) |  | 0% |  | 0% | 7 | 7 | 20 | 20 | 1 | 1 |
removeQueue(CSQueue) |  | 0% |  | 0% | 6 | 6 | 19 | 19 | 1 | 1 |
updateNodeLabelsAndQueueResource(NodeLabelsUpdateSchedulerEvent) |  | 0% |  | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
getSchedulerContainersToRelease(CSAssignment) |  | 0% |  | 0% | 10 | 10 | 20 | 20 | 1 | 1 |
printSchedulerInitialized() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
handleQueueCreationError(ApplicationId, String, String, boolean, Exception) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
setEntitlement(String, QueueEntitlement) |  | 0% |  | 0% | 4 | 4 | 17 | 17 | 1 | 1 |
attemptAllocationOnNode(SchedulerApplicationAttempt, SchedulingRequest, SchedulerNode) |  | 0% |  | 0% | 5 | 5 | 19 | 19 | 1 | 1 |
completedContainerInternal(RMContainer, ContainerStatus, RMContainerEventType) |  | 0% |  | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
markContainerForKillable(RMContainer) |  | 0% |  | 0% | 3 | 3 | 16 | 16 | 1 | 1 |
checkQueuePartition(FiCaSchedulerApp, AbstractLeafQueue) |  | 0% |  | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
getMaximumResourceCapability(String) |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
checkAccess(UserGroupInformation, QueueACL, String) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
shouldSkipNodeSchedule(FiCaSchedulerNode, CapacityScheduler, boolean) |  | 0% |  | 0% | 7 | 7 | 11 | 11 | 1 | 1 |
doneApplication(ApplicationId, RMAppState) |  | 0% |  | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
markContainerForNonKillable(RMContainer) |  | 0% |  | 0% | 2 | 2 | 13 | 13 | 1 | 1 |
getSchedulerContainer(RMContainer, boolean) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
nodeUpdate(RMNode) |  | 0% |  | 0% | 2 | 2 | 13 | 13 | 1 | 1 |
updateNodeAttributes(NodeAttributesUpdateSchedulerEvent) |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
canAllocateMore(CSAssignment, int, int) |  | 0% |  | 0% | 8 | 8 | 8 | 8 | 1 | 1 |
normalizeSchedulingRequests(List) |  | 0% |  | 0% | 5 | 5 | 10 | 10 | 1 | 1 |
getNodesHeartbeated(String) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
getCsConfProvider(Configuration) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
refreshLabelToNodeCache(Set) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
getPlanQueues() |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
getQueueInfo(String, boolean, boolean) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
CapacityScheduler() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
allocateContainersOnMultiNodes(CandidateNodeSet) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
markContainerForPreemption(ApplicationAttemptId, RMContainer) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
getCandidateNodeSet(FiCaSchedulerNode) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
getAddedAppQueueName(AppAddedSchedulerEvent) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
isPrintSkippedNodeLogging(CapacityScheduler) |  | 0% |  | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
initializeQueues(CapacitySchedulerConfiguration) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
submitResourceCommitRequest(Resource, CSAssignment) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getMaximumApplicationLifetime(String) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
serviceStop() |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
updateNodeAndQueueResource(RMNode, ResourceOption) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
addNodes(List) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
reinitializeQueues(CapacitySchedulerConfiguration) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
initMultiNodePlacement() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
initResourceCalculator() |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
serviceInit(Configuration) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getCSMappingPlacementRule() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
updateSchedulerNodeHBIntervalMetrics(NodeUpdateSchedulerEvent) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
getCandidateNodeSet(String) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
removeAutoCreatedQueue(CSQueue) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
getAppsInQueue(String) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getQueueUserAclInfo() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
getSchedulingResourceTypes() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
killReservedContainer(RMContainer) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
handleMoveToPlanQueue(String) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
startSchedulerThreads() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
isSystemAppsLimitReached() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
removeQueue(String) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
addQueue(Queue) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
normalizeQueueName(String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
initAsyncSchedulingProperties() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getQueue(String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getMutableConfProvider() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$updateAttributesOnNode$2(Set, NodeId) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getNodesHeartbeated$0(boolean, FiCaSchedulerNode) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getNodesHeartbeated$1(Map, FiCaSchedulerNode) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
reinitialize(Configuration, RMContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
updateAttributesOnNode(List, Set) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getNode(NodeId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
validateConf(Configuration) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
serviceStart() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
isAmbiguous(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getApplicationAttempt(ApplicationAttemptId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setConf(Configuration) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getRootQueueMetrics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRootQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContainerTokenSecretManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setResourceCalculator(ResourceCalculator) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getNumClusterNodes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setRMContext(RMContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAsyncScheduleInterval() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setAsyncSchedulingConf(CapacityScheduler.AsyncSchedulingConfiguration) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAllNodes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
killContainer(RMContainer) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getClusterResourceUsage() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAsyncSchedulingPendingBacklogs() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isConfigurationMutable() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumAsyncSchedulerThreads() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setMaxRunningAppsEnforcer(CSMaxRunningAppsEnforcer) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setQueueManager(CapacitySchedulerQueueManager) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAsyncSchedulerThreads() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConf() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConfiguration() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueueContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResourceCalculator() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRMContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDefaultReservationQueueName(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPreemptionManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCapacitySchedulerQueueManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getWorkflowPriorityMappingsManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCsConfProvider() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isMultiNodePlacementEnabled() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingApplicationComparator() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
resetSchedulerMetrics() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
placementConstraintEnabled() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
recover(RMStateStore.RMState) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |