小编Car*_*arl的帖子

Spark 2.0 Scala - RDD.toDF()

我正在使用Spark 2.0 Scala.我可以使用toDF()方法将RDD转换为DataFrame.

val rdd = sc.textFile("/pathtologfile/logfile.txt")
val df = rdd.toDF()
Run Code Online (Sandbox Code Playgroud)

但是对于我的生活,我无法在API文档中找到它的位置.它不属于RDD.但它在DataSet下(链接1).但是我有一个RDD而不是DataSet.

我也看不出它的含义(链接2).

所以请帮助我理解为什么可以为我的RDD调用toDF().这个方法从哪里继承?

scala apache-spark

15
推荐指数
2
解决办法
4万
查看次数

标签 统计

apache-spark ×1

scala ×1