【问题标题】:Spark Scala: value add is not a member of scala.collection.mutable.ListBufferSpark Scala:增值不是 scala.collection.mutable.ListBuffer 的成员
【发布时间】: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


    【解决方案1】:

    在 ListBuffer 中使用 +=:rowList += row

    【讨论】:

      【解决方案2】:

      add 不是标准的 ListBuffer API。只需要导入以下行:

      import scala.collection.JavaConversions._
      

      【讨论】:

        猜你喜欢
        • 1970-01-01
        • 2016-09-17
        • 2015-05-04
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 2017-11-28
        相关资源
        最近更新 更多