From 7921281e476ddedf028039e3639aac8fbbbf59da Mon Sep 17 00:00:00 2001 From: Scott Donnelly Date: Wed, 23 Apr 2025 08:08:02 +0100 Subject: [PATCH] feat: add equality_ids to FileScanTaskDeleteFile Needed to correctly apply equality deletes --- crates/iceberg/src/scan/task.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/crates/iceberg/src/scan/task.rs b/crates/iceberg/src/scan/task.rs index a5f4e4629..3369ffdaa 100644 --- a/crates/iceberg/src/scan/task.rs +++ b/crates/iceberg/src/scan/task.rs @@ -98,6 +98,7 @@ impl From<&DeleteFileContext> for FileScanTaskDeleteFile { file_path: ctx.manifest_entry.file_path().to_string(), file_type: ctx.manifest_entry.content_type(), partition_spec_id: ctx.partition_spec_id, + equality_ids: ctx.manifest_entry.data_file.equality_ids.clone(), } } } @@ -113,4 +114,7 @@ pub struct FileScanTaskDeleteFile { /// partition id pub partition_spec_id: i32, + + /// equality ids for equality deletes (empty for positional deletes) + pub equality_ids: Vec, }