Thank you very much Sourav
BR
Em 3/26/14, 17:29, Sourav Chandra escreveu:
def print() {
def foreachFunc = (rdd: RDD[T], time: Time) => {
val total = rdd.collect().toList
println ("-------------------------------------------")
println ("Time: " + time)
println ("-------------------------------------------")
total.foreach(println)
// val first11 = rdd.take(11)
// println ("-------------------------------------------")
// println ("Time: " + time)
// println ("-------------------------------------------")
// first11.take(10).foreach(println)
// if (first11.size > 10) println("...")
println()
}
new ForEachDStream(this,
context.sparkContext.clean(foreachFunc)).register()
}
--
Informativa sulla Privacy: http://www.unibs.it/node/8155
