summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2021-11-16 13:21:57 +0100
committerTor Brede Vekterli <vekterli@yahooinc.com>2021-11-17 11:08:08 +0100
commit35adcc568a0265e20ffdcb8add3db8558ea9c350 (patch)
treed75734ba370b0e7394a34c13d6f58594e724d103 /configserver
parentda9a7ce37b73405dd8ae936b3b8a52d2b2b816f1 (diff)
Add feature flag for unordered merge chaining
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java3
1 files changed, 3 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java
index 83d139ce461..3630215913e 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java
@@ -198,6 +198,7 @@ public class ModelContextImpl implements ModelContext {
private final boolean forwardIssuesAsErrors;
private final boolean asyncApplyBucketDiff;
private final boolean ignoreThreadStackSizes;
+ private final boolean unorderedMergeChaining;
public FeatureFlags(FlagSource source, ApplicationId appId) {
this.defaultTermwiseLimit = flagValue(source, appId, Flags.DEFAULT_TERM_WISE_LIMIT);
@@ -234,6 +235,7 @@ public class ModelContextImpl implements ModelContext {
this.forwardIssuesAsErrors = flagValue(source, appId, PermanentFlags.FORWARD_ISSUES_AS_ERRORS);
this.asyncApplyBucketDiff = flagValue(source, appId, Flags.ASYNC_APPLY_BUCKET_DIFF);
this.ignoreThreadStackSizes = flagValue(source, appId, Flags.IGNORE_THREAD_STACK_SIZES);
+ this.unorderedMergeChaining = flagValue(source, appId, Flags.UNORDERED_MERGE_CHAINING);
}
@Override public double defaultTermwiseLimit() { return defaultTermwiseLimit; }
@@ -272,6 +274,7 @@ public class ModelContextImpl implements ModelContext {
@Override public boolean forwardIssuesAsErrors() { return forwardIssuesAsErrors; }
@Override public boolean asyncApplyBucketDiff() { return asyncApplyBucketDiff; }
@Override public boolean ignoreThreadStackSizes() { return ignoreThreadStackSizes; }
+ @Override public boolean unorderedMergeChaining() { return unorderedMergeChaining; }
private static <V> V flagValue(FlagSource source, ApplicationId appId, UnboundFlag<? extends V, ?, ?> flag) {
return flag.bindTo(source)