【发布时间】:2016-05-21 07:36:56
【问题描述】:
下面是我的代码,尝试将数据框行添加到列表中,然后以元组的形式返回。
导入 scala.collection.mutable.ListBuffer
myDF.rdd.filter{row:Row => row.getString(6).length > 0}.map {
row: Row =>
var rowList: ListBuffer[Row] = ListBuffer()
rowList.add(row)
(row.getString(1) + "_" + row.getString(2) + "_" + row.getString(6) + "_" + row.getString(7) + "_" + row.getString(14), rowList)
}.count()
然后我得到以下错误:
error: value add is not a member of scala.collection.mutable.ListBuffer[org.apache.spark.sql.Row]
rowList.add(row)
有谁知道我在这里做错了什么?谢谢!
【问题讨论】:
标签: scala apache-spark apache-spark-sql