I'm a newbie with Spark,,, a simple question
val errorLines = lines.filter(_.contains("h"))
val mapErrorLines = errorLines.map(line => ("key", line))
val grouping = errorLinesValue.groupByKeyAndWindow(Seconds(8), Seconds(4))
I get something like:
604: -------------------------------------------
605: Time: 1418832180000 ms
606: -------------------------------------------
607: (key,ArrayBuffer(h2, h3, h4))
Now, I would like to get that ArrayBuffer and count the number of elements,,
How could I get that arrayBuffer??? something like:
val values = grouping.getValue()... How could I do this in Spark with Scala?
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
