apache-spark - spark SQL-Tungsten Aggregate 和 Tungsten Exchange 是什么意思？

Question

我在 SparkSQL 数据帧上运行一个非常简单的 count()，这里是 Web UI 中的一些相应 DAG。

TungstenAggregate 和 TungstenExchange 指的是什么？ (谷歌搜索没有结果。)

代码:

ndata2 = sqlContext.createDataFrame(sc.textFile(filePath).map(lambda x : x.split(",")),["key","value"])
ndata2.count()

Answer 1

根据 this comment通过 zero323，

TungstenExchange is a shuffle.

不过，我还是很想知道 TungstenAggregate 是什么。