summaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorHåvard Pettersen <havardpe@yahooinc.com>2023-04-28 13:07:55 +0200
committerHåvard Pettersen <havardpe@yahooinc.com>2023-04-28 13:07:55 +0200
commitec495469099fc26c64736fd103facc25f8370a26 (patch)
treeb79057f3f3baa05d4ba65968598563867a7464f2 /vespaclient-core
parent8cf2f720a10e3d06c69fd43a6fdfab1a59274036 (diff)
pick up create flag for put operations
Diffstat (limited to 'vespaclient-core')
-rw-r--r--vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java9
1 files changed, 7 insertions, 2 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
index d8b69bd4a85..2b67df00e12 100644
--- a/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/Feeder.java
@@ -80,8 +80,13 @@ public abstract class Feeder {
while (!sender.isAborted()) {
try {
FeedOperation op = reader.read();
- if (createIfNonExistent && op.getDocumentUpdate() != null) {
- op.getDocumentUpdate().setCreateIfNonExistent(true);
+ if (createIfNonExistent) {
+ if (op.getDocumentUpdate() != null) {
+ op.getDocumentUpdate().setCreateIfNonExistent(true);
+ }
+ if (op.getDocumentPut() != null) {
+ op.getDocumentPut().setCreateIfNonExistent(true);
+ }
}
if (op.getType() == FeedOperation.Type.INVALID) break; // Done feeding
sender.sendOperation(op);