将 RDD[Map[String,Double]] 转换为 RDD[(String,Double)]
Convert RDD[Map[String,Double]] to RDD[(String,Double)]
我做了一些计算并在包含 scala 映射的 RDD 中返回了我的值，现在我想删除这个映射并想在 RDD 中收集所有键值。
我们将不胜感激。
你可以调用带有身份函数的 flatMap 来 'flatten' 你的 RDD 的结构。
rdd.flatMap(identity)
我做了一些计算并在包含 scala 映射的 RDD 中返回了我的值，现在我想删除这个映射并想在 RDD 中收集所有键值。
我们将不胜感激。
你可以调用带有身份函数的 flatMap 来 'flatten' 你的 RDD 的结构。
rdd.flatMap(identity)