| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
Sorry, something went wrong.
Mirrors the existing StreamExecCalc shadow so native execution also covers BATCH mode's Calc operator, reusing NativePlanFusionBuilder and FlinkAuronCalcOperator unchanged. Fusion codegen and source fusion are out of scope for this first step. Relates to apache#1264
| Back | FazBrowse Home | New Git URL |
Which issue does this PR close?
TBD
Rationale for this change
Flink's BATCH mode currently has no native execution: DefaultPlannerFactory routes it to the stock, unmodified BatchPlanner. NativePlanFusionBuilder and FlinkAuronCalcOperator are already engine-agnostic (no streaming-specific types), so the smallest correct first step is a BatchExecCalc shadow reusing both, mirroring the existing StreamExecCalc shadow.
What changes are included in this PR?
No changes to any streaming file or to DefaultPlannerFactory.
Are there any user-facing changes?
Yes: BATCH queries now get native execution for Calc (projection/filter) when auron-flink-assembly is ahead of stock flink-table-planner on the classpath. Falls back to Flink's codegen Calc when not convertible, matching existing streaming behavior.
How was this patch tested?
Draft while a dedicated BatchExecCalcTest (mirroring StreamExecCalcTest) is added.
Was this patch authored or co-authored using generative AI tooling?
ASF guidance: https://www.apache.org/legal/generative-tooling.html