Spark矢量化 spark 向量化执行

在SPARK的计算向量化-spark本身的向量化中，我们提到spark是利用代码生成（生成for循环），从而JIT进行向量化。这是有局限的，所以大部分公司都会采用通过其他方式来进行向量化计算。 我们列举几种已知的应用到spark计算引擎的向量化技术。

Meta（也就是Facebook）开源的一个C++实现的SQL执行引擎，输入逻辑执行计划，利用SIMD指令实现向量化操作，输出结果; 结合Apache Arrow作数据交换，可以实现Spark的计算向量化。 项目见facebookincubator/velox

这是Databricks执行引擎的内部实现，也是用C++实现的，但是它复用了spark的逻辑计划，在物理计划task级别进行判断哪些是可以运行在Photon，具体执行位置如下：

Intel开源的,底层依赖于Apache Arrow高效数据存储和Gandiva（基于LLVM）的高效向量计算，但是Gandiva目前只是支持表达式向量化，不支持sort，join这种物理算子。

项目见:gazelle_plugin

DataFusion（是Apache Arrow的一部分） 是用Rust语言实现的,使用Apache Arrow作为内存格式的向量化计算引擎框架，它支持用SQL和DataFrame API构建逻辑计划，以及能够使用线程对分区数据源（CSV 和 Parquet）并行执行的查询优化器和执行引擎。

项目见：arrow-datafusion（2k的星）

Blaze是基于 arrow datafusion 向量化执行引擎构建的 Spark 加速器。它从 Spark获取一个完全优化的物理计划，将其映射到 DataFusion 的执行计划中，并在Spark executor中计算，同时结合了DataFusion 库的强大功能和 Spark 分布式计算框架的可扩展性。

项目见：blaze-init/blaze

Intel开源的解藕spark jvm和native SQL执行引擎的项目，它利用substrait进行解藕，通过把spark的物理计划转换为对应的substrait plan，之后再传递到后台的native SQL backend执行引擎执行。当然也是利用了Apache Arrow作为数据存储。

项目见：oap-project/gluten

我们知道在spark内部，spark的数据都是按行处理的，但是如果我们进行了native向量化以后，为了高效的进行向量化计算，内部的数据传输采用的都是列格式，所以在Native sql引擎侧的话，就得采用列格式的shuffle，这样才会更好的提升后续的operator计算效率（如果还是采用基于行格式的shuffle的话，就得进行类似ColumnarToRow和RowToColumnar的操作，这大大降低了整体的性能），columnar shuffle操作如下（聚合操作）：