Scala - 加入两个 RDD 后如何连接列表和选项值？

Question

我有两个想要加入的 RDD - salesfromSource1: RDD[(String, List[Sale])] 和 filteredSales: RDD[(String, Sale)]

由于我想执行左连接，我尝试了以下方法：

val joinedSales: RDD[(String, (List[Sale], Option[Sale]))] = salesfromSource1.leftOuterJoin(filteredSales)

但是如何连接这些值以便得到RDD[(String, List[InvocaCall])]？

我希望通过.mapValues(_._1 ::: _._2) 实现这一目标

但是我得到一个类型不匹配的编译器突出显示(expected (List[Sale], Option[Sale]) => NotinferedU, actual: (Any, Any) => Any)

Answer 1

例如这样：

.mapValues {
   case (x, None) => x
   case (x, Some(y)) => x :: y
}

或

.mapValues { x =>
  x._2.map(y => x._1 :: y).getOrElse(x._1)
}