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

发布时间：2020-12-16 18:09:09 所属栏目：安全来源：网络整理

导读：说如果我这样做,如下所示. val rdd = sc.textFile("someFile.txt")val rddWithLines = rdd.zipWithIndex zipWithIndex添加的索引是否与输入文件中的行号(当然第一行为0)相对应？或者在这种情况下订单是否破裂？解决方法 zipWithIndex是一个仅限地图的转换(

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

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

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

解决方法

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!