尝试：

val rdds = Seq(
  sc.parallelize(Seq(1, 3, 5)),
  sc.parallelize(Seq(3, 5)),
  sc.parallelize(Seq(1, 3))
)
rdds.map(rdd => rdd.map(x => (x, None))).reduce((x, y) => x.join(y).keys.map(x => (x, None))).keys

rdd上有一个交集方法，但它只需要另一个rdd：

def intersection(other: RDD[T]): RDD[T]

让我们用这个来实现你想要的方法。

def intersectRDDs[T](rdds: Seq[RDD[T]]): RDD[T] = {
  rdds.reduce { case (left, right) => left.intersection(right) 
}

如果您已经了解了spark连接的实现，可以通过将最大的rdd放在第一位来优化执行：

def intersectRDDs[T](rdds: Seq[RDD[T]]): RDD[T] = {
  rdds.sortBy(rdd => -1 * rdd.partitions.length)
    .reduce { case (left, right) => left.intersection(right) 
}

编辑：看起来我误读了您的示例：您的文本看起来像是在搜索rdd.union的反向行为，但您的示例暗示您希望按键相交。我的回答不涉及这个问题。