Flink Table API&SQL中涉及到的查询优化有哪些?

提问者:帅平 问题分类:面试刷题
Flink Table API&SQL中涉及到的查询优化有哪些?
1 个回答
有个笨蛋住进我心
有个笨蛋住进我心
Apache Flink 使用并扩展了 Apache Calcite 来执行复杂的查询优化。 这包括一系列基于规则和成本的优化,例如:
基于 Apache Calcite 的子查询解相关
投影剪裁
分区剪裁
过滤器下推
子计划消除重复数据以避免重复计算
特殊子查询重写,包括两部分:(将 IN 和 EXISTS 转换为 left semi-joins,将 NOT IN 和 NOT EXISTS 转换为 left anti-join)
可选 join 重新排序(通过 table.optimizer.join-reorder-enabled 启用)
发布于:9个月前 (08-18) IP属地:四川省
我来回答