如何与不同的JavaPairRDD互连

Question

我有两个不同的值，一个是Key1，JavaPairRdd，另一个是key2，value。我试图实现的是合并它们，但只得到具有相同值的项。

我尝试过以下几种方法：

 JavaPairRDD<String, String> finalRdd = filteredRdd.intersection(filteredsmallRdd);

其中filteredRdd包含key:Country，value，而filteredsmallRdd包含: key:id，value。我需要哪些元素具有相同的值，对于交集，我认为比较唯一的键，我得到了一个空解，你知道怎么做吗？

Answer 1

您可以使用swap来更改作为每个rdd的键的值，然后执行交集。

JavaPairRDD<String,String> finalRdd = filteredRdd.mapToPair(f -> f.swap()).intersection(filteredsmallRdd.mapToPair(f -> f.swap()));