Add equality_ids to FileScanTaskDeleteFile (#1235)

sdd · web-flow · commit c34982a89aa4 · 2025-04-23T22:03:22.000+08:00
diff --git 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<i32>,
 }

Original file line number	Diff line number	Diff line change
`@@ -98,6 +98,7 @@ impl From<&DeleteFileContext> for FileScanTaskDeleteFile {`
`98`	`98`	`file_path: ctx.manifest_entry.file_path().to_string(),`
`99`	`99`	`file_type: ctx.manifest_entry.content_type(),`
`100`	`100`	`partition_spec_id: ctx.partition_spec_id,`
	`101`	`+ equality_ids: ctx.manifest_entry.data_file.equality_ids.clone(),`
`101`	`102`	`}`
`102`	`103`	`}`
`103`	`104`	`}`
`@@ -113,4 +114,7 @@ pub struct FileScanTaskDeleteFile {`
`113`	`114`
`114`	`115`	`/// partition id`
`115`	`116`	`pub partition_spec_id: i32,`
	`117`	`+`
	`118`	`+ /// equality ids for equality deletes (empty for positional deletes)`
	`119`	`+ pub equality_ids: Vec<i32>,`
`116`	`120`	`}`