diff options
author | Geir Storli <geirst@verizonmedia.com> | 2021-11-05 13:47:18 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2021-11-05 13:47:18 +0000 |
commit | b994f19b89973f75664ce71f1dad58ffd541f246 (patch) | |
tree | 18400b332631a195557ef74a27f987a144c8a458 /configserver/src/main | |
parent | c7d50a638da8d991254c3cc3c151d95ea5ef8b51 (diff) |
Add feature flag for whether to use a shared field writer executor for the document database(s) in proton.
Diffstat (limited to 'configserver/src/main')
-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 98e65724468..a824433ae69 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 @@ -168,6 +168,7 @@ public class ModelContextImpl implements ModelContext { private final boolean useThreePhaseUpdates; private final String feedSequencer; private final int feedTaskLimit; + private final String sharedFieldWriterExecutor; private final String responseSequencer; private final int numResponseThreads; private final boolean skipCommunicationManagerThread; @@ -203,6 +204,7 @@ public class ModelContextImpl implements ModelContext { this.useThreePhaseUpdates = flagValue(source, appId, Flags.USE_THREE_PHASE_UPDATES); this.feedSequencer = flagValue(source, appId, Flags.FEED_SEQUENCER_TYPE); this.feedTaskLimit = flagValue(source, appId, Flags.FEED_TASK_LIMIT); + this.sharedFieldWriterExecutor = flagValue(source, appId, Flags.SHARED_FIELD_WRITER_EXECUTOR); this.responseSequencer = flagValue(source, appId, Flags.RESPONSE_SEQUENCER_TYPE); this.numResponseThreads = flagValue(source, appId, Flags.RESPONSE_NUM_THREADS); this.skipCommunicationManagerThread = flagValue(source, appId, Flags.SKIP_COMMUNICATIONMANAGER_THREAD); @@ -238,6 +240,7 @@ public class ModelContextImpl implements ModelContext { @Override public boolean useThreePhaseUpdates() { return useThreePhaseUpdates; } @Override public String feedSequencerType() { return feedSequencer; } @Override public int feedTaskLimit() { return feedTaskLimit; } + @Override public String sharedFieldWriterExecutor() { return sharedFieldWriterExecutor; } @Override public String responseSequencerType() { return responseSequencer; } @Override public int defaultNumResponseThreads() { return numResponseThreads; } @Override public boolean skipCommunicationManagerThread() { return skipCommunicationManagerThread; } |