2016-04-26 5 views
0

私はApache Sparkを初めて使用しています。タイトルには、JavaPairRdd<String,String>があり、キーとJavaPairRddの値を連結してJavaRdd<String>を生成したいと考えています。これは可能ですか?キーと値を連結してJavaPairRddをJavaRddに変換する

例:

("1,Nick", "[email protected],53") 
("2,John", "[email protected],53") 

結果(とJavaRdd<String>):

スカラ座を使用している
pairRDD.map((key, value) => key + value) 

ていますが、要点を取得する必要があります:

"1,Nick,[email protected],53" 
"2,John,[email protected],53" 

答えて

1

ちょうどmapを使用しています。

関連する問題