Check for tombstones in wrapping storage adapters (apache#16791)

kfaraz · Jul 25, 2024 · b5f117b · b5f117b
1 parent 14954c7
commit b5f117b
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 0 deletions.
diff --git a/processing/src/main/java/org/apache/druid/segment/FilteredStorageAdapter.java b/processing/src/main/java/org/apache/druid/segment/FilteredStorageAdapter.java
@@ -142,4 +142,10 @@ public Metadata getMetadata()
   {
     return baseStorageAdapter.getMetadata();
   }
+
+  @Override
+  public boolean isFromTombstone()
+  {
+    return baseStorageAdapter.isFromTombstone();
+  }
 }
diff --git a/processing/src/main/java/org/apache/druid/segment/UnnestStorageAdapter.java b/processing/src/main/java/org/apache/druid/segment/UnnestStorageAdapter.java
@@ -256,6 +256,12 @@ public Metadata getMetadata()
     return baseAdapter.getMetadata();
   }
 
+  @Override
+  public boolean isFromTombstone()
+  {
+    return baseAdapter.isFromTombstone();
+  }
+
   public VirtualColumn getUnnestColumn()
   {
     return unnestColumn;

diff --git a/processing/src/main/java/org/apache/druid/segment/join/HashJoinSegmentStorageAdapter.java b/processing/src/main/java/org/apache/druid/segment/join/HashJoinSegmentStorageAdapter.java
@@ -227,6 +227,12 @@ public boolean canVectorize(@Nullable Filter filter, VirtualColumns virtualColum
     return clauses.isEmpty() && baseAdapter.canVectorize(baseFilterAnd(filter), virtualColumns, descending);
   }
 
+  @Override
+  public boolean isFromTombstone()
+  {
+    return baseAdapter.isFromTombstone();
+  }
+
   @Nullable
   @Override
   public VectorCursor makeVectorCursor(