内容简介：今天跟大家聊聊如何在Flink Table&SQL程序中修改Calcite优化规则集。我们在实现流和维表Join的时候，发现Flink逻辑计划规则集中的当我们实现流和维表join的时候，当有非等值的where条件时，这部分的实现得由特定的维表查询自行实现。所以，我们暂时不能在这个feature中使用该规则。那么我们该如何调整或自定义Flink所使用的全局规则呢？
今天跟大家聊聊如何在Flink Table&SQL程序中修改Calcite优化规则集。
我们在实现流和维表Join的时候，发现Flink逻辑计划规则集中的 FilterJoinRule.FILTER_ON_JOIN 不能在这种场景下使用。这个规则用于将处于Join节点之上或内部的filter下推到join节点和/或其子节点。
当我们实现流和维表join的时候，当有非等值的where条件时，这部分的实现得由特定的维表查询自行实现。所以，我们暂时不能在这个feature中使用该规则。那么我们该如何调整或自定义Flink所使用的全局规则呢？
Apache Flink利用Apache Calcite来优化和翻译查询。当前执行的优化包括投影和filter谓词下推下推，子查询去相关以及其他类型的查询重写。Flink尚未优化join的顺序，而是以查询中定义的相同顺序执行它们（FROM子句中的表的顺序和/或WHERE子句中的join谓词的顺序）。默认情况下，Flink在内部给出了它目前支持的默认规则集。它们以不同的类别被定义在 FlinkRuleSets.scala 中。
但它也对外保持了扩展性，允许用户对逻辑优化规则集与物理优化规则集进行修改。通过提供CalciteConfig对象，可以调整在不同阶段应用的优化规则集。这可以通过调用 CalciteConfig.createBuilder() 通过构建器创建，并通过调用 tableEnv.getConfig.setCalciteConfig(calciteConfig) 提供给TableEnvironment。
例如，这里如果我们要移除 FilterJoinRule.FILTER_ON_JOIN ，我们可以这样：
当然，除此之外，还允许你更改更多的规则集，例如：
-
replaceNormRuleSet;
-
replacePhysicalOptRuleSet;
-
replaceDecoRuleSet
-
...
Have fun!
以上所述就是小编给大家介绍的《Tips: Flink Table&SQL修改优化规则集》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
