美文网首页
【Spark】SparkOptimizer 优化:Optimiz

【Spark】SparkOptimizer 优化:Optimiz

作者: PowerMe | 来源:发表于2017-12-14 11:08 被阅读48次

最近在调试Spark-SQL的时候看了一个OptimizeIn优化规则,该规则做了两个事情:

  1. 去除In中重复的Literal条件;
  2. 如果In中Literal条件数目大于optimizerInSetConversionThreshold(默认值为10),做In到InSet的表达式转换。

在做DataSource扩展filter pushdown的时候要注意处理这种优化。

源码如下:

  • image.png

    实例:

  • image.png

相关文章

网友评论

      本文标题:【Spark】SparkOptimizer 优化:Optimiz

      本文链接:https://www.haomeiwen.com/subject/smwhwxtx.html