diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-08 09:41:10 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-08 14:43:42 +0000 |
commit | 3f3021757fbfa2c1002c0bf3055a734a374fc8bd (patch) | |
tree | 56680ae3fdd437b141ece35a3be89f6b91699da9 /container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java | |
parent | 6d60d82bebd617880b2737d9f549b8402a1e1f24 (diff) |
Revert "Revert "Disable topk optimisation on dispatch when content distribution is se…""
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java index 2f62b07ac04..56165ec150b 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java @@ -368,6 +368,12 @@ public class SearchCluster implements NodeManager<Node> { return workingNodes + nodesAllowedDown >= nodesInGroup; } + public boolean isGroupWellBalanced(OptionalInt groupId) { + if (groupId.isEmpty()) return false; + Group group = groups().get(groupId); + return (group != null) && group.isContentWellBalanced(); + } + /** * Calculate whether a subset of nodes in a group has enough coverage */ |