Java等价于Spark的Join操作答案

【问题标题】：Java Equivalent to Spark's Join OperationJava等价于Spark的Join操作
【发布时间】：2016-09-06 20:46:01
【问题描述】：

因为 Apache Spark 提供了一种便捷的方式来加入pair RDDs

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

我想知道在 vanilla Java 中是否有类似的可能？

例如两张地图

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

屈服

Map<K, Set<V>>

提前致谢。

【问题讨论】：

【解决方案1】：

没有。

您必须创建一个新地图并以某种方式遍历键/值（您可以使用漂亮的新流 api 来做到这一点）。

或者看看番石榴的多图。

【讨论】：

【解决方案2】：

我认为你可以使用leftOuterJoin()：

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

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

【讨论】：