将RDD的Iterable [(String,Double)]更改为Array或List

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)}