Konvertieren von JavaPairRdd in JavaRdd durch Verketten von Schlüssel und Wert

Question

Ich bin neu bei Apache Spark. Wie der Titel sagt, habe ich eine JavaPairRdd<String,String> und ich möchte eine JavaRdd<String> mit der Verkettung des Schlüssels und den Wert der JavaPairRdd produzieren. Ist das möglich?

Beispiel:

("1,Nick", "mail@sth.com,53") 
("2,John", "mail@sth.com,53") 

Ergebnis (JavaRdd<String> mit):

"1,Nick,mail@sth.com,53" 
"2,John,mail@sth.com,53" 

Answer 1

Nur verwenden map:

pairRDD.map((key, value) => key + value) 

Das scala verwendet, aber Sie sollten den Kern erhalten.