FlinkSQL查询执行阶段
FlinkSQL的查询执行阶段主要包括以下几个步骤：
解析阶段是将SQL文本转换为语法树（SqlNode）的过程。在这个过程中，FlinkSQL使用Apache
Calcite的解析器来解析SQL语句。解析器会将SQL语句分解为一系列的词汇单元，并构建出一个树形结构的语法树。
校验阶段是检查SQL语句的合法性，确保它符合SQL规范。在这个过程中，FlinkSQL使用Catalog中的元数据信息进行语法分析和验证。如果SQL语句合法，那么就会继续进行后续的处理；否则，就会抛出异常。
转换阶段是将语法树转换为关系代数表达式（RelNode）。在这个过程中，FlinkSQL使用Optimizer将关系代数表达式转换为逻辑执行计划。逻辑执行计划是一个树形结构，根节点对应最上层的Select语句，叶子节点对应输入表的TableScan操作，Join和Where条件过滤分别对应了Join和Filter节点。
执行阶段是根据前面生成的逻辑执行计划生成物理执行计划（PhysicalPlan），并利用Codegen技术生成高效执行代码。在这个过程中，FlinkSQL会利用表达式折叠（ExpressionReduce）、下推优化（Predicate/Projection
Pushdown）等优化技术生成物理执行计划。然后，根据物理执行计划，Flink会生成相应的算子，并将这些算子组成执行计划。
以上就是FlinkSQL查询执行的基本流程。在这个过程中，FlinkSQL利用Apache
Calcite进行了SQL解析和逻辑执行计划生成，然后通过自身的优化技术生成物理执行计划，并最终利用Codegen技术生成高效执行代码。
