通过连接键和值将 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>与）：

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

Answer 1

只需使用 map:

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

那是在使用 scala，但您应该了解要点。