从地图列表创建多个地图

Question

所以我有一个如下的RDD：

RDD[(Map[DateTime, Int],  //X
     Map[DateTime, Int],  //Y
     Map[DateTime, Int],  //Z
     Map[DateTime, Int],  //P
     Map[DateTime, Int],  //T
     Map[DateTime, Int])] //F

每一个都代表不同类型的映射，例如X,Y,Z,T,P,F。我想做的是将X-Map中的所有值加在一起，然后将Y-Maps中的所有值加起来等等。 最后，我想得到 6 个不同的 Map[DateTime, Int] 代表这些类型中的每一个。

Answer 1

这很简单：

rdd.reduce{
  case ((x1, y1, z1, p1, t1, f1), (x2, y2, z2, p2, t2, f2)) =>
    (x1 ++ x2, y1 ++ y2, z1 ++ z2, p1 ++ p2, t1 ++ t2, f1 ++ f2)
}