2016-07-12 3 views
-1

DataFrameの変数rawDataがあります。私は列のすべての要素を取得し、Scala Seqに変換する必要があります。RDDをシーケンスに変換できません

val res = rawData.map(x => x(0)).toSeq 

しかし、私は次のエラーを取得しています:

Error:(114, 40) value toSeq is not a member of org.apache.spark.rdd.RDD[Any] 
    val res = rawData.map(x => x(0)).toSeq 

のでrawData.map(x => x(0))はタイプRDD[Any]です。 Seqに変換するにはどうすればよいですか?

答えて

3

例外として、toSeqはRDDオブジェクトのメンバーではありません。あなたのために簡単にする。

val res = rawData.map(x => x(0)).collect() 

このコマンドは、反復処理を行う場合は、シーケンスオブジェクトを返します。

関連する問題