spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From julyfire <>
Subject Re: Windowed Operations
Date Fri, 10 Oct 2014 10:06:56 GMT
hi Diego,

I have the same problem.

// reduce by key in the first window
val *w1* = *one*.reduceByKeyAndWindow(_ + _, Seconds(30), Seconds(10))

//reduce by key in the second window based on the results of the first
val *w2* = *w1*.reduceByKeyAndWindow(_ + _, Seconds(120), Seconds(30))

then w1 works, but w2 always does not print any information.

Do you have any update for this issue?

View this message in context:
Sent from the Apache Spark User List mailing list archive at

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message