diff options
author | Tor Brede Vekterli <vekterli@vespa.ai> | 2024-04-12 11:54:16 +0200 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@vespa.ai> | 2024-04-12 11:57:22 +0200 |
commit | b805ba686f175b9a3fb6182e36348c093fb78c72 (patch) | |
tree | b11e3aa4ebc2f7b271318991cd4096f4f7b483f0 /config-model/src/main/java/com/yahoo/config/model | |
parent | 1d8cd8366c4d918459f2df1c873eb2206f1c1e11 (diff) |
Add feature flag for controlling max feed operation batch size
Currently defaults to 1, which disables batching.
Diffstat (limited to 'config-model/src/main/java/com/yahoo/config/model')
-rw-r--r-- | config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java | 7 |
1 files changed, 7 insertions, 0 deletions
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 3e91b8afe88..51c78ee796c 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 @@ -82,6 +82,7 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea private boolean allowUserFilters = true; private List<DataplaneToken> dataplaneTokens; private int contentLayerMetadataFeatureLevel = 0; + private int persistenceThreadMaxFeedOpBatchSize = 1; @Override public ModelContext.FeatureFlags featureFlags() { return this; } @Override public boolean multitenant() { return multitenant; } @@ -138,6 +139,7 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea @Override public boolean allowUserFilters() { return allowUserFilters; } @Override public List<DataplaneToken> dataplaneTokens() { return dataplaneTokens; } @Override public int contentLayerMetadataFeatureLevel() { return contentLayerMetadataFeatureLevel; } + @Override public int persistenceThreadMaxFeedOpBatchSize() { return persistenceThreadMaxFeedOpBatchSize; } public TestProperties sharedStringRepoNoReclaim(boolean sharedStringRepoNoReclaim) { this.sharedStringRepoNoReclaim = sharedStringRepoNoReclaim; @@ -368,6 +370,11 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea return this; } + public TestProperties setPersistenceThreadMaxFeedOpBatchSize(int maxBatchSize) { + this.persistenceThreadMaxFeedOpBatchSize = maxBatchSize; + return this; + } + public static class Spec implements ConfigServerSpec { private final String hostName; |