apache-spark - 配对两个 RDD-s

Question

假设我有两个 RDD，其中一个是另一个的映射。例如:

RDD[Double] N;
RDD[Double] logN = N.map(x => Math.Log(x));

我想对它们的匹配对进行操作。像这样的事情:

RDD[Double] NlogN = (N,logN).map((x,y) => x*y);

spark中有这种操作吗？

Answer 1

您正在寻找zip

N.zip(logN).map { case (x, y) => ... }