第 10 篇：「Table API 与 SQL 总览」—— 一条 SQL 如何被 Calcite 编译成 Flink 的 Transformation

仓库：https://github.com/apache/flink
官方文档：https://nightlies.apache.org/flink/flink-docs-lts/
技术栈：Java 11 / Scala / Apache Calcite / Planner SPI / RelNode / ExecNode / Transformation
解读版本：release-1.20.5（commit 0980485）
解读视角：总架构师评审（架构 / 源码 / 生产 / 进阶）

第 10 篇：「Table API 与 SQL 总览」—— 一条 SQL 如何被 Calcite 编译成 Flink 的 Transformation

阅读本文你将了解：

1. Flink 的 Planner 是可插拔 SPI——Planner/Parser/Executor 三个接口加三个 Factory，流批由 DefaultPlannerFactory 按 RUNTIME_MODE 分派（flink-table/flink-table-planner/src/main/java/org/apache/flink/table/

转载自 CSDN-专业IT技术社区

原文链接：https://blog.csdn.net/u010804586/article/details/164590231