JavaPairRDDの相違点

Question

私は2つの異なるJavaPairRddをKey1、value、もう1つはkey2、valueを持っています。達成しようとしているのはそれらをマージすることですが、同じ値を持つアイテムだけを取得します。

は、私は、次の試してみました：国、値とfilteredsmallRddが含まれています：キー：ID、値をfilteredRddキーが含まれてい

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

。どの要素が同じ値を持っている必要があります。交差点では、唯一のキーを比較して空の解を得て、それをどうするか考えていますか？

Answer 1

swapを使用して、各rddのキーとして値を変更して交差を実行できます。

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