如何将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(","))

您可以根据需要更改","参数.

希望对您有所帮助,最诚挚的问候.