Ensure deleted keys are not dropped when aggregating

NationalSecurityAgency · Apr 16, 2024 · 5fef9df · 5fef9df
1 parent 20030aa
commit 5fef9df
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/datawave/iterators/FrequencyMetadataAggregator.java b/src/main/java/datawave/iterators/FrequencyMetadataAggregator.java
@@ -244,6 +244,9 @@ private void updateCache() throws IOException {
             if (!workKey.isDeleted()) {
                 // Aggregate the current entry.
                 aggregateCurrent();
+            } else {
+                // Add the deleted entry to the cache so that it is available for scanning, but do not include it as part of the aggregation.
+                cache.put(super.getTopKey(), super.getTopValue());
             }
 
             // Advance to the next entry from the source.