return number of inserts and deletions in update metadata

ad-freiburg · Feb 8, 2025 · e21c5fb · e21c5fb
1 parent 13c4347
commit e21c5fb
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/src/engine/ExecuteUpdate.cpp b/src/engine/ExecuteUpdate.cpp
@@ -182,6 +182,8 @@ ExecuteUpdate::computeGraphUpdateQuads(
   };
   sortAndRemoveDuplicates(toInsert);
   sortAndRemoveDuplicates(toDelete);
+  metadata.inUpdate = DeltaTriplesCount{static_cast<int64_t>(toInsert.size()),
+                                        static_cast<int64_t>(toDelete.size())};
   std::vector<IdTriple<>> reducedToDelete;
   ql::ranges::set_difference(std::move(toDelete), toInsert,
                              std::back_inserter(reducedToDelete));

diff --git a/src/engine/ExecuteUpdate.h b/src/engine/ExecuteUpdate.h
@@ -17,6 +17,7 @@ struct UpdateMetadata {
   Milliseconds triplePreparationTime_ = Zero;
   Milliseconds insertionTime_ = Zero;
   Milliseconds deletionTime_ = Zero;
+  std::optional<DeltaTriplesCount> inUpdate;
 };
 
 class ExecuteUpdate {

diff --git a/src/engine/Server.cpp b/src/engine/Server.cpp
@@ -961,6 +961,10 @@ json Server::createResponseMetadataForUpdate(
   response["delta-triples"]["after"] = nlohmann::json(countAfter);
   response["delta-triples"]["difference"] =
       nlohmann::json(countAfter - countBefore);
+  if (updateMetadata.inUpdate.has_value()) {
+    response["delta-triples"]["operation"] =
+        json(updateMetadata.inUpdate.value());
+  }
   response["time"]["planning"] =
       formatTime(runtimeInfoWholeOp.timeQueryPlanning);
   response["time"]["where"] =