datafusion-contrib / datafusion-contrib/datafusion-distributed
[Iceberg] Write data files for append inserts
Nobody has claimed this yet.
- Dominant language
- Rust
- Stars
- 139
- Forks
- 67
- Avg merge
- 3d 1h
- Merged PRs (30d)
- 35
Description
Part of #599.
Implement the physical write path that turns DataFusion input batches into Iceberg data files for append inserts.
Upstream starts this with IcebergWriteExec here:
It needs partition-value projection, partition-aware repartitioning and sorting, task writers, rolling Parquet writers, and DataFile output.
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start with the upstream IcebergWriteExec implementation in crates/integrations/datafusion/src/physical_plan/write.rs, lines 53-90, then inspect the corresponding local DataFusion integration. Map the work across partition projection, repartitioning and sorting, task writers, rolling Parquet writers, and DataFile output. Done means append input batches produce partition-aware Iceberg data files with DataFile results.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- rust
- Domain
- data-engineering, databases, distributed-systems
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Quiet
- Clarity
- Mostly clear
- Newbie friendliness
- 35/100