【Flink】FlinkSQL中执行计划以及如何用代码看执行计划

FilnkSQL怎么查询优化

Apache Flink 使用并扩展了 Apache Calcite 来执行复杂的查询优化。 这包括一系列基于规则和成本的优化，例如：

• 基于 Apache Calcite 的子查询解相关

• 投影剪裁

• 分区剪裁

• 过滤器下推

• 子计划消除重复数据以避免重复计算

• 特殊子查询重写，包括两部分：

◦ 将 IN 和 EXISTS 转换为 left semi-joins

◦ 将 NOT IN 和 NOT EXISTS 转换为 left anti-join

• 可选 join 重新排序

◦ 通过 table.optimizer.join-reorder-enabled 启用

注意： 当前仅在子查询重写的结合条件下支持 IN / EXISTS / NOT IN / NOT EXISTS。

优化器不仅基于计划，而且还基于可从数据源获得的丰富统计信息以及每个算子（例如 io，cpu，网络和内存）的细粒度成本来做出明智的决策。

高级用户可以通过 CalciteConfig 对象提供自定义优化，可以通过调用 TableEnvironment＃getConfig＃setPlannerConfig 将其提供给 TableEnvironment。

FilnkSQL用什么代码查看优化

Table API 提供了一种机制来解释计算 Table