From 06d9dff6eb2d27e02083a599ffd91bb12fc26ec0 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Sat, 20 Aug 2022 00:50:43 +0200 Subject: Add featureflag control over query dispatch policy. --- .../src/main/java/com/yahoo/config/model/deploy/TestProperties.java | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'config-model/src/main/java/com/yahoo/config/model/deploy') diff --git a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java index 400aea86834..8e2f3feb010 100644 --- a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java +++ b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java @@ -41,6 +41,7 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea private boolean useThreePhaseUpdates = false; private double defaultTermwiseLimit = 1.0; private String jvmGCOptions = null; + private String queryDispatchPolicy = "adaptive"; private String sequencerType = "THROUGHPUT"; private boolean firstTimeDeployment = false; private String responseSequencerType = "ADAPTIVE"; @@ -147,6 +148,7 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea @Override public int mbusCppEventsBeforeWakeup() { return mbus_cpp_events_before_wakeup; } @Override public int rpcNumTargets() { return rpc_num_targets; } @Override public int rpcEventsBeforeWakeup() { return rpc_events_before_wakeup; } + @Override public String queryDispatchPolicy() { return queryDispatchPolicy; } public TestProperties sharedStringRepoNoReclaim(boolean sharedStringRepoNoReclaim) { @@ -192,6 +194,10 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea jvmGCOptions = gcOptions; return this; } + public TestProperties setQueryDispatchPolicy(String policy) { + queryDispatchPolicy = policy; + return this; + } public TestProperties setFeedSequencerType(String type) { sequencerType = type; return this; -- cgit v1.2.3