HHH*_*HHH 1 scala apache-spark
我正在开发一个我有一个Spark应用程序RDD[Array[Array[Float]],我想把它转换成一个RDD[Float].我有以下代码为我执行此任务:
val values = predictions.flatMap { x => (for(y <- 0 to x.length - 1) yield x(y)).map(c => c(0)) }
Run Code Online (Sandbox Code Playgroud)
但是我不知道使用后是否改变了元素的顺序flatMap?如果是这样,是否有任何其他解决方案保持元素的顺序完整?
| 归档时间: |
|
| 查看次数: |
850 次 |
| 最近记录: |