Thanks again Tathagata for your help
Best Regards
On Jan 20, 2014, at 19:11, Tathagata Das tathagata.das1...@gmail.com wrote:
Hi Eduardo,
You can do arbitrary stuff with the data in a DStream using the operation
foreachRDD.
yourDStream.foreachRDD(rdd = {
// Get and print first n
Hi guys,
Somebody help me, Where do I get change the print() function to print more than
10 lines in screen? Is there a manner to print the count total of all words in
a batch?
Best Regards
--
---
INFORMATIVA SUL TRATTAMENTO DEI DATI PERSONALI
I dati utilizzati per l'invio del presente
Hi Eduardo,
You can do arbitrary stuff with the data in a DStream using the operation
foreachRDD.
yourDStream.foreachRDD(rdd = {
// Get and print first n elements
val firstN = rdd.take(n)
println(First N elements = + firstN)
// Count the number of elements in each batch
