scala - 字符串RDD连接操作

Question

我在 scala 中有字符串 RDD。字符串是 id。事情大概是这样的。

1
2
3
4

我有另一个 RDD，其 (id, name) 如下。

(1, Name1)
(2, Name2)
(3, Name3)
(4, Name4)
(5, Name5)
(6, Name6)

现在我想要获取第一个 RDD 中所有 id 的名称。我该怎么做？

我意识到，如果第一个 RDD 是pairRDD，我就可以加入这两个 RDD。那么为什么我们只有pairRDD的join操作呢？

Answer 1

试试这个:

rdd1.map(x => (x, null)).join(rdd2).mapValues(x => x._2)