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。文章来源：https://www.toymoban.com/news/detail-410213.html
FilnkSQL用什么代码查看优化
Table API 提文章来源地址https://www.toymoban.com/news/detail-410213.html
到了这里，关于【Flink】FlinkSQL中执行计划以及如何用代码看执行计划的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
