相當於Java星火的加入操作

Question

因爲Apache星火提供了一個便捷的方式加入pair RDDs

JavaPairRDD<K,scala.Tuple2<V,W>> join(JavaPairRDD<K,W> other) 

我在想，如果類似的東西有可能在香草的Java？

例如兩張地圖

Map<K, V>, Map<K, V> 

產生提前

Map<K, Set<V>> 

感謝。

Answer 1

我認爲你可以使用leftOuterJoin()：

JavaPairRdd<K,V> left; 
JavaPairRdd<K,V> right; 

JavaPairRdd<K, Tuple2<V, Optional<V>>> joined = left.leftOuterJoin(right); 

Answer 2

號

你會以某種方式通過創建鍵/值新的地圖和路（你可以用漂亮的新流做API）。

或者看看番石榴的多圖。