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

说如果我这样做，如下所示。

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

zipWithIndex 添加的索引是否对应于输入文件中的行号(当然第一行是 0)？还是在这种情况下订单被破坏了？

最佳答案

zipWithIndex 是一个仅限 map 的转换(它不会随机播放)，所以顺序是正确的。您可以在这里安全地使用它。