Skip to content

[Spark] Introduce codegen support for whole stage merge query - #9390

Open
ArnavBalyan wants to merge 2 commits into
apache:masterfrom
ArnavBalyan:arnavb/merge-codegen-spark
Open

[Spark] Introduce codegen support for whole stage merge query#9390
ArnavBalyan wants to merge 2 commits into
apache:masterfrom
ArnavBalyan:arnavb/merge-codegen-spark

Conversation

@ArnavBalyan

@ArnavBalyan ArnavBalyan commented Aug 25, 2026

Copy link
Copy Markdown
Member

Purpose

  • Paimon processes merge queries through JVM and runs a scala iterator for every joined row.
  • Add support for whole stage codegen for matched and unmatched actions. With keep/discard/split functions support.
  • This optimization is config driven and enabled with spark.paimon.write.merge.codegen.enabled. Spark's upstream operator reports 1.7x to 32.3x improvements with wholestage on.

Tests

  • UT

@ArnavBalyan ArnavBalyan changed the title [Spark] Introduce codegen support for whole stage merge queries [Spark] Introduce codegen support for whole stage merge query Aug 25, 2026
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.

1 participant