tutorial spark sources receive foreachrdd example data context scala enumerate

scala - sources - spark streaming python



¿Hay un equivalente de Scala para la enumeración de python? (1)

Puedes usar el zipWithIndex del rasgo zipWithIndex :

for ((line, i) <- Source.fromFile(args(0)).getLines().zipWithIndex) { println(i, line) }

Me gustaría la conveniencia de

for i, line in enumerate(open(sys.argv[1])): print i, line

Al hacer lo siguiente en Scala.

for (line <- Source.fromFile(args(0)).getLines()) { println(line) }