Skip to content

Commit b3a8601

Browse files
committed
feat(datafusion): implement the project node to add the partition columns defined in Iceberg.
Implement physical execution plan node that projects Iceberg partition columns from source data, supporting nested fields and all Iceberg transforms.
1 parent bc469c3 commit b3a8601

File tree

2 files changed

+667
-0
lines changed

2 files changed

+667
-0
lines changed

crates/integrations/datafusion/src/physical_plan/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
pub(crate) mod commit;
1919
pub(crate) mod expr_to_predicate;
2020
pub(crate) mod metadata_scan;
21+
pub(crate) mod project;
2122
pub(crate) mod scan;
2223
pub(crate) mod write;
2324

0 commit comments

Comments
 (0)