aboutsummaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@yahooinc.com>2023-02-28 15:09:48 +0100
committerBjørn Christian Seime <bjorncs@yahooinc.com>2023-02-28 15:09:48 +0100
commita79e364692a3470b489ade4d12368df451601d1c (patch)
tree1c9c61e6acaacf6cde83823d2a93fdd618c1ce41 /container-search
parentfd9d20d62003b677f172ca07603c657f89873088 (diff)
Introduce feature flag to enable global phase
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
index 7787d7d7702..08d8d54bc53 100644
--- a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
+++ b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
@@ -66,6 +66,7 @@ public class ClusterSearcher extends Searcher {
private final VespaBackEndSearcher server;
private final Executor executor;
private final GlobalPhaseRanker globalPhaseHelper;
+ private final boolean enableGlobalPhase;
@Inject
public ClusterSearcher(ComponentId id,
@@ -105,6 +106,7 @@ public class ClusterSearcher extends Searcher {
server = searchDispatch(searchClusterIndex, searchClusterName, uniqueServerId,
docSumParams, documentDbConfig, schemaInfo, dispatchers);
}
+ enableGlobalPhase = searchClusterConfig.globalphase();
}
private static QrSearchersConfig.Searchcluster getSearchClusterConfigFromClusterName(QrSearchersConfig config, String name) {
@@ -164,6 +166,7 @@ public class ClusterSearcher extends Searcher {
server = searcher;
this.executor = executor;
this.globalPhaseHelper = null;
+ this.enableGlobalPhase = false;
}
/** Do not use, for internal testing purposes only. **/
@@ -245,7 +248,7 @@ public class ClusterSearcher extends Searcher {
}
String schema = restrict.iterator().next();
Result result = searcher.search(query, execution);
- if (globalPhaseHelper != null) {
+ if (globalPhaseHelper != null && enableGlobalPhase) {
globalPhaseHelper.process(query, result, schema);
}
return result;