我在 SparkSQL 数据帧上运行一个非常简单的 count()
,这里是 Web UI 中的一些相应 DAG。
TungstenAggregate 和 TungstenExchange 指的是什么? (谷歌搜索没有结果。)
代码:
ndata2 = sqlContext.createDataFrame(sc.textFile(filePath).map(lambda x : x.split(",")),["key","value"])
ndata2.count()
最佳答案
关于apache-spark - spark SQL-Tungsten Aggregate 和 Tungsten Exchange 是什么意思?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38795557/