ResourceManagerClusterStateProvider

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total938 of 9380%60 of 600%63631921923333
getClusterMemoryPoolInfoInternal()1490%120%77343411
ResourceManagerClusterStateProvider(InternalNodeManager, SessionPropertyManager, int, Duration, Duration, Duration, Duration, Duration, boolean, ScheduledExecutorService)1230%40%33222211
lambda$getClusterResourceGroups$9(Map, BasicQueryInfo)770%140%88161611
computeAdjustedQueueSize()590%20%22121211
validateCoordinatorConsistency()530%40%339911
registerQueryHeartbeat(String, BasicQueryInfo, long)450%n/a11101011
lambda$computeAdjustedQueueSize$6(Map, ResourceGroupRuntimeInfo)410%20%229911
getClusterResourceGroups(String)370%n/a11111111
ResourceManagerClusterStateProvider(InternalNodeManager, SessionPropertyManager, ResourceManagerConfig, NodeMemoryConfig, ScheduledExecutorService)350%n/a11121211
lambda$new$2(Duration)310%40%335511
lambda$new$1(Duration)310%40%335511
registerNodeHeartbeat(NodeStatus)300%20%226611
lambda$getWorkerMemoryInfo$14(Map.Entry)270%n/a113311
getRunningTaskCount()220%n/a118811
lambda$getLargestMemoryQuery$13(ResourceManagerClusterStateProvider.Query, ResourceManagerClusterStateProvider.Query)200%20%225511
lambda$new$0()170%20%224411
getClusterQueries()150%n/a115511
lambda$registerQueryHeartbeat$5(String, String)130%n/a113311
registerResourceGroupRuntimeHeartbeat(String, List)120%n/a112211
getLargestMemoryQuery(Optional, ResourceManagerClusterStateProvider.Query)120%n/a114411
isQueryExpired(ResourceManagerClusterStateProvider.Query, long, long)110%20%221111
getWorkerMemoryInfo()100%n/a111111
lambda$getClusterMemoryPoolInfoInternal$12(ResourceManagerClusterStateProvider.Query)90%20%221111
lambda$getClusterResourceGroups$7(String, ResourceManagerClusterStateProvider.CoordinatorQueriesState)90%20%221111
lambda$getRunningTaskCount$10(BasicQueryInfo)80%20%221111
lambda$new$3()70%n/a112211
getAdjustedQueueSize()60%n/a111111
lambda$getWorkerMemoryInfo$15(Map.Entry)60%n/a111111
getClusterMemoryPoolInfo()50%n/a111111
isQueryCompleted(ResourceManagerClusterStateProvider.Query)50%n/a111111
lambda$registerQueryHeartbeat$4(String, InternalNode)50%n/a111111
lambda$getClusterMemoryPoolInfoInternal$11(ResourceManagerClusterStateProvider.InternalNodeState)40%n/a111111
lambda$getClusterResourceGroups$8(BasicQueryInfo)40%n/a111111