2016-05-20 4 views
1

以下は私のコードです。データフレームの行をリストに追加し、タプルで返します。Spark Scala:value addはscala.collection.mutable.ListBufferのメンバーではありません

輸入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) 

誰も私がここで間違って何をしたか知っていますか?ありがとう!

答えて

1

addは、標準のListBuffer APIではありません。

import scala.collection.JavaConversions._ 
2

使用+ = ListBuffer中:rowList + =行

だけで次の行をインポートする必要があります
関連する問題