scala - 将RDD的Iterable [(String，Double)]更改为数组或列表

Question

我有一个org.apache.spark.rdd.RDD[(String, (Double, Double), Iterable[(String, Double)])]，但使用Iterable似乎很困难。有什么办法可以将其更改为Array[(String, Double)]吗？

Answer 1

您可以简单地使用Iterable.toArray

rdd.map{case (x, y, iter) => (x, y, iter.toArray)}

或Iterable.toList

rdd.map{case (x, y, iter) => (x, y, iter.toList)}