2016-11-29 33 views
0

私はcsvファイルに書き込むことを望んでいたRDD[(Int, Double)]という形式の比較的小さなRDDを持っています。RDDをCSVファイルに書き込む

Main.scala:111: ambiguous reference to overloaded definition, 
[error] both method saveAsTextFile in class RDD of type (path: String, codec: Class[_ <: org.apache.hadoop.io.compress.CompressionCodec])Unit 
[error] and method saveAsTextFile in class RDD of type (path: String)Unit 
[error] match expected type ? 
[error] }.saveAsTextFile 
[error] ^

任意の提案:しかし、私は以下のエラーを受信して​​い

val myRdd.map{case(a, b) => 
    var line = a.toString + "," + b.toString 
    line 
}.saveAsTextFile 

:?Writing a RDD to a csvでロジックに続いて、私は以下のコードになってしまいましたかあなたがパスを提供しなければならない

答えて

2

val myRdd.map{case(a, b) => 
    var line = a.toString + "," + b.toString 
    line 
}.saveAsTextFile("path"); 

両方のローカルおよびHDFSパスが正しいです。 Hereは文書です

+0

はい - リンクされた質問の回答にはエラー –

+0

が含まれています。問題を解決したパスを提示してください - 提案を感謝してください。 – mongolol

+0

笑、6分、私ができるまで数える:P – mongolol

関連する問題