将RDD[Map[String,Double]]转换为RDD[(String,Double)]



我做了一些计算,并在一个包含标量映射的RDD中返回了我的值,现在我想删除这个映射,并收集RDD中的所有键值。

任何帮助都将不胜感激。

您可以使用identity函数调用flatMap来"压平"RDD的结构。

rdd.flatMap(identity)

最新更新