小编Vic*_*ter的帖子

我有一个名为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..

谢谢

我有一个名为samparr的Array [String]，其中包含一些值，我希望将其存储为输出文件。

var samparr: Array[String] = new Array[String](4)
samparr +:= print1 + "  BEST_MATCH  " + print2

就像，

val output = samparr.saveAsTextFile(outputpath)

但不是RDD，而是一个Array [String]