diff options
author | Tor Brede Vekterli <vekterli@yahooinc.com> | 2021-11-16 13:21:57 +0100 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahooinc.com> | 2021-11-17 11:08:08 +0100 |
commit | 35adcc568a0265e20ffdcb8add3db8558ea9c350 (patch) | |
tree | d75734ba370b0e7394a34c13d6f58594e724d103 /configserver | |
parent | da9a7ce37b73405dd8ae936b3b8a52d2b2b816f1 (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.java | 3 |
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) |