如何在Scala中将DataFrame转换为RDD？

Vaj*_*jra 38 scala apache-spark apache-spark-sql spark-dataframe

有人可以分享一下如何将一个转换dataframe成一个RDD？

只是:

val rows: RDD[Row] = df.rdd

Run Code Online (Sandbox Code Playgroud)

如果您为RDD或Row获得"未找到类型",这可能会有所帮助:`val rows:org.apache.spark.rdd.RDD [org.apache.spark.sql.Row] = df.rdd` (4认同)

归档时间：	9 年，12 月前
查看次数：	66848 次
最近记录：	7 年，6 月前

在Play框架和OAuth2上保护REST API 41

Scala作为新的Java？ 33

SPARK SQL - 使用DataFrames和JDBC更新MySql表 19

Scala中运行时的结构化等于 12

使用SBT创建新的Scala项目？ 10

理解Scala for For循环的范围(理解) 9

如何使用ScalaMock模拟call-by-name参数(如getOrElse)？ 8

我可以用scala.Singleton做什么？ 8

KeyError:SparkConf初始化期间的SPARK_HOME 3

Pyspark 在写入时用 Null 值填充我的列 2

如何删除远程标签？ 3121

在Git存储库中查找并恢复已删除的文件 2716

如何在JavaScript中获取查询字符串值？ 2701

如何在Bash中连接字符串变量 2624

如何将Git托管项目中的所有本地更改还原到以前的状态？ 1830

在C++中将int转换为字符串的最简单方法 1488

在视图控制器之间传递数据 1340

如何使用sed替换换行符(\n)？ 1295

如何从GET参数中获取值？ 1255

有哪些常用的命名git分支实例的例子？ 1034