Spark Catalyst 源码分析(八)

2014-11-24 00:14:04 · 作者: · 浏览: 9
es { val hiveContext = self override val strategies: Seq[Strategy] = Seq( TopK, ColumnPrunings, PartitionPrunings, HiveTableScans, DataSinks, Scripts, PartialAggregation, SparkEquiInnerJoin, BasicOperators, CartesianProduct, BroadcastNestedLoopJoin ) }

Summary

之前的那篇Spark SQL组件 源码分析走读了SQLContext的整个执行过程,有很多内容不够具体。本文结合Catalyst,做了更详细的说明。

全文完 :)