Skip to content

[spark] partition filter pushdown for non-lake log and kv tables#3240

Open
fresh-borzoni wants to merge 2 commits intoapache:mainfrom
fresh-borzoni:feat/spark-partition-filter-pushdown
Open

[spark] partition filter pushdown for non-lake log and kv tables#3240
fresh-borzoni wants to merge 2 commits intoapache:mainfrom
fresh-borzoni:feat/spark-partition-filter-pushdown

Conversation

@fresh-borzoni
Copy link
Copy Markdown
Member

@fresh-borzoni fresh-borzoni commented May 2, 2026

Summary

closes #3241

Push partition predicates to the planner so partitioned queries skip non-matching partitions instead of issuing per-partition reads.

Mirrors Flink's partitionFilters path. Covers non-lake append and PK tables.

Lake enabled are left as a follow-up.

@fresh-borzoni fresh-borzoni force-pushed the feat/spark-partition-filter-pushdown branch from 829748d to 319ce1a Compare May 2, 2026 11:29
@fresh-borzoni
Copy link
Copy Markdown
Member Author

@Yohahaha @YannByron PTAL 🙏

@fresh-borzoni fresh-borzoni force-pushed the feat/spark-partition-filter-pushdown branch from 319ce1a to 0590289 Compare May 2, 2026 14:10
Copy link
Copy Markdown
Contributor

@Yohahaha Yohahaha left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM! only one comments, thank you!

@fresh-borzoni
Copy link
Copy Markdown
Member Author

@Yohahaha Ty for the review, addressed.

@luoyuxia Can you take a quick look, pls?

@fresh-borzoni fresh-borzoni force-pushed the feat/spark-partition-filter-pushdown branch from 2929835 to 45d1bc7 Compare May 8, 2026 17:32
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[spark] partition filter pushdown for non-lake log and kv tables

2 participants