通过连接键和值将 JavaPairRdd 转换为 JavaRdd

Question

我是 Apache Spark 的新手。正如标题所说，我有一个JavaPairRdd<String,String>，我想生成一个JavaRdd<String>，其中包含键和JavaPairRdd 的值的连接。这可能吗？

例子：

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

结果（JavaRdd<String> with）：

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

Answer 1

只需使用map：

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

这是使用 scala，但你应该明白要点。