lambda$createNodeMapSupplier$2(Optional, ConnectorId) |  | 0% |  | 0% | 9 | 9 | 36 | 36 | 1 | 1 |
NodeScheduler(NetworkLocationCache, NetworkTopology, InternalNodeManager, NodeSelectionStats, NodeSchedulerConfig, NodeTaskMap, Duration, NodeTtlFetcherManager, QueryManager, SimpleTtlNodeSelectorConfig) |  | 0% |  | 0% | 5 | 5 | 28 | 28 | 1 | 1 |
selectDistributionNodes(NodeMap, NodeTaskMap, long, long, int, Set, List, BucketNodeMap, NodeSelectionStats) |  | 0% |  | 0% | 5 | 5 | 21 | 21 | 1 | 1 |
createNodeSelector(Session, ConnectorId, int, Optional) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
selectExactNodes(NodeMap, List, boolean) |  | 0% |  | 0% | 7 | 7 | 26 | 26 | 1 | 1 |
toWhenHasSplitQueueSpaceFuture(Set, List, long) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
getTopologicalSplitCounters() |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
selectNodes(int, ResettableRandomizedIterator) |  | 0% |  | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
canAssignSplitToDistributionNode(NodeAssignmentStats, InternalNode, long, long, int, SplitWeight) |  | 0% |  | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
NodeScheduler(NetworkTopology, InternalNodeManager, NodeSelectionStats, NodeSchedulerConfig, NodeTaskMap, NodeTtlFetcherManager, QueryManager, SimpleTtlNodeSelectorConfig) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
randomizedNodes(NodeMap, boolean, Set) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
canAssignSplitBasedOnWeight(long, long, SplitWeight) |  | 0% |  | 0% | 4 | 4 | 1 | 1 | 1 | 1 |
toWhenHasSplitQueueSpaceFuture(List, long) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$randomizedNodes$3(boolean, NodeMap, InternalNode) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
lambda$selectExactNodes$6(boolean, Set, InternalNode) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
lambda$selectExactNodes$5(boolean, Set, InternalNode) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
lambda$randomizedNodes$4(Set, InternalNode) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
createNodeSelector(Session, ConnectorId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createNodeSelector(Session, ConnectorId, Optional) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createNodeSelector(Session, ConnectorId, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
calculateLowWatermark(long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$null$0(Node) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
createNodeMapSupplier(ConnectorId, Optional) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
stop() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$toWhenHasSplitQueueSpaceFuture$8(long, RemoteTask) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$toWhenHasSplitQueueSpaceFuture$7(long, RemoteTask) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$null$1(Node) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |