diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-04-27 14:51:50 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-04-27 14:51:50 +0200 |
commit | 10c64dec098e1b5109eb07c0c43a879b8cc38c0b (patch) | |
tree | 738753a148c1160a2a37105e8e228afb5ed9e946 /vespaclient-java | |
parent | 8993b9df81bf0acbbe42db002a202f46f019e7e6 (diff) |
Remove common ConditionalFeedOperation
Diffstat (limited to 'vespaclient-java')
-rw-r--r-- | vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java | 25 |
1 files changed, 18 insertions, 7 deletions
diff --git a/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java b/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java index e29e32aee92..c4dfe6b26f1 100644 --- a/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java +++ b/vespaclient-java/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java @@ -35,7 +35,6 @@ import com.yahoo.messagebus.SourceSessionParams; import com.yahoo.messagebus.StaticThrottlePolicy; import com.yahoo.messagebus.network.rpc.RPCNetworkParams; import com.yahoo.messagebus.routing.Route; -import com.yahoo.vespaxmlparser.ConditionalFeedOperation; import com.yahoo.vespaxmlparser.FeedReader; import com.yahoo.vespaxmlparser.FeedOperation; import com.yahoo.vespaxmlparser.RemoveFeedOperation; @@ -285,33 +284,45 @@ public class SimpleFeeder implements ReplyHandler { } } - static class LazyDocumentOperation extends ConditionalFeedOperation { + static class LazyDocumentOperation extends FeedOperation { private final DocumentDeserializer deserializer; + private final TestAndSetCondition condition; LazyDocumentOperation(DocumentDeserializer deserializer, TestAndSetCondition condition) { - super(Type.DOCUMENT, condition); + super(Type.DOCUMENT); this.deserializer = deserializer; + this.condition = condition; } @Override public DocumentPut getDocumentPut() { DocumentPut put = new DocumentPut(new Document(deserializer)); - put.setCondition(getCondition()); + put.setCondition(condition); return put; } + @Override + public TestAndSetCondition getCondition() { + return condition; + } } - static class LazyUpdateOperation extends ConditionalFeedOperation { + static class LazyUpdateOperation extends FeedOperation { private final DocumentDeserializer deserializer; + private final TestAndSetCondition condition; LazyUpdateOperation(DocumentDeserializer deserializer, TestAndSetCondition condition) { - super(Type.UPDATE, condition); + super(Type.UPDATE); this.deserializer = deserializer; + this.condition = condition; } @Override public DocumentUpdate getDocumentUpdate() { DocumentUpdate update = new DocumentUpdate(deserializer); - update.setCondition(getCondition()); + update.setCondition(condition); return update; } + @Override + public TestAndSetCondition getCondition() { + return condition; + } } @Override |