Rectangle 27 0

hadoop Spark RDD: Get row number?


val rdd2 = rdd1.zipWithIndex.filter{ 
    case (row, index) => {
      // row number is index. (but is not fixed, unless RDD is sorted)
}
Note