diff --git a/processing/src/main/java/org/apache/druid/segment/FilteredStorageAdapter.java b/processing/src/main/java/org/apache/druid/segment/FilteredStorageAdapter.java index 2b32860698fa..1168e34b28af 100644 --- 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 index ff4994210e1d..752c6f486786 100644 --- 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 index fd9c07a253fb..9dade664f8ac 100644 --- 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(