将 Iterable[(Double, Double)] 转换为 Seq(Seq(Double))

Question

我想将 Pair RDD "myRDD" 值从 Iterable[(Double,Double)] 转换为 Seq(Seq(Double))，但是我不知道该怎么做。我尝试了以下但它不起作用。

val groupedrdd: RDD[BB,Iterable[(Double,Double)]] = RDDofPoints.groupByKey()
val RDDofSeq = groupedrdd.mapValues{case (x,y) => Seq(x,y)}

myRDD 是使用 RddofPoints 上的 groupByKey 操作形成的，它们各自的边界框作为键。 BB 是一个案例类，它是类型为 (Double,Double) 的一组点的键。我希望 RDDofSeq 的类型为 RDD[BB,Seq(Seq(Double))]，但是在 groupByKey 之后，myRDD 的类型为 RDD[BB,Iterable[(Double,Double)]]。

这里会报错：

Error:(107, 58) constructor cannot be instantiated to expected type;
 found   : (T1, T2)
 required: Iterable[(Double, Double)]

我是 Scala 新手，感谢您提供这方面的任何帮助。谢谢。

ANSWER：以下内容用于实现上述目标：

val RDDofSeq = groupedrdd.mapValues{iterable => iterable.toSeq.map{case (x,y) => Seq(x,y)}}

Answer 1

我在Scalafiddle上试过这个

val myRDD: Iterable[(Double,Double)] = Seq((1.1, 1.2), (2.1, 2.2))

val RDDofSeq = myRDD.map{case (x,y) => Seq(x,y)}

println(RDDofSeq) // returns List(List(1.1, 1.2), List(2.1, 2.2))

唯一的区别是我用myRDD.map(..而不是myRDD.mapValues(..

确保myRDD 确实属于Iterable[(Double,Double)] 类型！

评论后更新：

如果我理解正确，您需要的是 Seq[Double] 而不是 Seq[Seq[Double]]

应该是这样的：

val RDDofSeq = myRDD.map{case (k,v) => v} // returns List(1.2, 2.2)

类型明确后更新：

这些值的类型为Iterable[(Double,Double)]，因此您无法匹配一对。

试试这个：

 val RDDofSeq = groupedrdd.mapValues{iterable => 
 Seq(iterable.head._1, iterable.head._2)}

Answer 2

你只需要map，而不是mapValues。

val RDDofSeq = myRDD.map{case (x,y) => Seq(x,y)}