Skip to content

Commit a4c0726

Browse files
committed
feat(writer): Add PositionDeleteFileWriter for position delete files
Add PositionDeleteFileWriter for writing position delete Parquet files per Iceberg spec. Position deletes use a specific schema with file_path (field ID 2147483546) and pos (field ID 2147483545) columns. - Add PositionDeleteWriterConfig with Iceberg spec field IDs - Implement PositionDeleteFileWriterBuilder with IcebergWriterBuilder trait - Implement PositionDeleteFileWriter with IcebergWriter trait - Track referenced_data_file for single-file delete optimization - Add comprehensive schema validation with detailed error messages - Add 13 tests covering edge cases, validation, and Parquet field IDs
1 parent 3d47be5 commit a4c0726

File tree

2 files changed

+1271
-0
lines changed

2 files changed

+1271
-0
lines changed

crates/iceberg/src/writer/base_writer/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,3 +19,4 @@
1919
2020
pub mod data_file_writer;
2121
pub mod equality_delete_writer;
22+
pub mod position_delete_writer;

0 commit comments

Comments
 (0)