Tips: Flink Table&SQL修改优化规则集

今天跟大家聊聊如何在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!