sc.textFile之后的zipWithIndex会给出正确的行号吗？

Question

说如果我这样做,如下所示.

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

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

Answer 1

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