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 ("
This works just fine without any compilation error:
def print() {
def foreachFunc = (rdd: RDD[T], time: Time) => {
val total = rdd.collect().toList
println ("---")
println ("Time: " + time)
println ("-
Thanks Guys for reply, but I have found this piece of code in streaming:
def print() {
585 def foreachFunc = (rdd: RDD[T], time: Time) => {
586 //val first11 = rdd.take(11)
587 //val first100 = rdd.take(100)
588 val total = rdd.collect()
589 println ("---
You can extend DStream and override print() method. Then you can create
your own DSTream extending from this.
On Tue, Mar 25, 2014 at 6:07 PM, Eduardo Costa Alfaia <
e.costaalf...@unibs.it> wrote:
> Hi Guys,
> I think that I already did this question, but I don't remember if anyone
> has answere
