scala - 如何将 RDD[Row] 转换为 RDD[String]

Question

我有一个名为 source 的 DataFrame，一个来自 mysql 的表

val source = sqlContext.read.jdbc(jdbcUrl, "source", connectionProperties)

我已将其转换为 rdd

val sourceRdd = source.rdd

但它的 RDD[Row] 我需要 RDD[String]
做像这样的转换

source.map(rec => (rec.split(",")(0).toInt, rec)), .subtractByKey(), etc..

谢谢

Answer 1

您可以使用 Row. mkString(sep: String): String map 中的方法像这样打电话:

val sourceRdd = source.rdd.map(_.mkString(","))

您可以更改 ","任何你想要的参数。

希望这对你有帮助，最好的问候。