大家好，我有一个 RDD[string]，我想在将它保存到文本文件之前向它添加一个标题，这里是我所做的代码
val projectionsTxt = rowMatrix.rows.map(l => l.toString.filter(c => c != '[' & c != ']'))
val res = projectionsTxt.map(p => {
var tokens = p.split(",")
for (i <- 0 to tokens.length - 1) {
tokens(i) = (BigDecimal(tokens(i)).setScale(2, BigDecimal.RoundingMode.HALF_UP).toDouble).toString()
}
tokens.mkString(",")
})
val header: RDD[String] = sc.parallelize(Array("col1","col2","col3"))
header.union(res).saveAsTextFile(strFilePath)
请提供任何帮助，我无法完成。我想获取数据及其标题。谢谢
try ：val header: RDD[String] = sc.parallelize(Array("col1,col2,col3"))
列 List 必须与 String ( = a line ) 匹配。你有一个 RDD[String] 。所以你必须声明一个包含一个“String”元素的数组。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句