scala – sc.textFile之后的zipWithIndex会给出正确的行号吗?

前端之家收集整理的这篇文章主要介绍了scala – sc.textFile之后的zipWithIndex会给出正确的行号吗?前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
说如果我这样做,如下所示.

val rdd = sc.textFile("someFile.txt")
val rddWithLines = rdd.zipWithIndex

zipWithIndex添加的索引是否与输入文件中的行号(当然第一行为0)相对应?或者在这种情况下订单是否破裂?

解决方法

zipWithIndex是一个仅限地图的转换(它不会随机播放),所以订单是正确的.你可以在这里安全地使用它.

猜你在找的Scala相关文章