将递增的整数 Id 添加到 JavaRDD答案

【问题标题】：Add increasing integer Id to a JavaRDD将递增的整数 Id 添加到 JavaRDD
【发布时间】：2017-11-23 12:10:46
【问题描述】：

我有一个简单的JavaRDD<String> 喜欢：

("a"),("b"),("c")...

现在我想为每个元素添加一个递增整数 id。关键是，我想自己定义开始 ID，例如：

("a",5),("b",6),("c",7)...

我知道zipWithIndex()，但是这个方法不能设置一个开始ID号。也许我可以先做zipwithIndex()然后再做map()来增加id，但是还有另一种显式的方法吗？

【问题讨论】：

【解决方案1】：

您可以使用.zipWithIndex，然后使用map 声明以使用您的用户定义的值来增加索引。

例如。 rdd.zipWithIndex.map(a=>(a._1,a._2+userDefinedIndexValue))

【讨论】：