getClusterMemoryPoolInfoInternal() |  | 0% |  | 0% | 7 | 7 | 34 | 34 | 1 | 1 |
ResourceManagerClusterStateProvider(InternalNodeManager, SessionPropertyManager, int, Duration, Duration, Duration, Duration, Duration, boolean, ScheduledExecutorService) |  | 0% |  | 0% | 3 | 3 | 22 | 22 | 1 | 1 |
lambda$getClusterResourceGroups$9(Map, BasicQueryInfo) |  | 0% |  | 0% | 8 | 8 | 16 | 16 | 1 | 1 |
computeAdjustedQueueSize() |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
validateCoordinatorConsistency() |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
registerQueryHeartbeat(String, BasicQueryInfo, long) |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
lambda$computeAdjustedQueueSize$6(Map, ResourceGroupRuntimeInfo) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
getClusterResourceGroups(String) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
ResourceManagerClusterStateProvider(InternalNodeManager, SessionPropertyManager, ResourceManagerConfig, NodeMemoryConfig, ScheduledExecutorService) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
lambda$new$2(Duration) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
lambda$new$1(Duration) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
registerNodeHeartbeat(NodeStatus) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$getWorkerMemoryInfo$14(Map.Entry) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getRunningTaskCount() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
lambda$getLargestMemoryQuery$13(ResourceManagerClusterStateProvider.Query, ResourceManagerClusterStateProvider.Query) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$new$0() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getClusterQueries() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$registerQueryHeartbeat$5(String, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
registerResourceGroupRuntimeHeartbeat(String, List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getLargestMemoryQuery(Optional, ResourceManagerClusterStateProvider.Query) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
isQueryExpired(ResourceManagerClusterStateProvider.Query, long, long) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getWorkerMemoryInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getClusterMemoryPoolInfoInternal$12(ResourceManagerClusterStateProvider.Query) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getClusterResourceGroups$7(String, ResourceManagerClusterStateProvider.CoordinatorQueriesState) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getRunningTaskCount$10(BasicQueryInfo) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$new$3() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAdjustedQueueSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getWorkerMemoryInfo$15(Map.Entry) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getClusterMemoryPoolInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isQueryCompleted(ResourceManagerClusterStateProvider.Query) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$registerQueryHeartbeat$4(String, InternalNode) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getClusterMemoryPoolInfoInternal$11(ResourceManagerClusterStateProvider.InternalNodeState) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getClusterResourceGroups$8(BasicQueryInfo) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |