You're just describing the normal operation of Spark Streaming them. Windowing is for when you want overlapping intervals. Here you simply do not window, and ask for intervals of whatever time you want. You get non-overlapping RDDs.
On Wed, Jan 14, 2015 at 9:26 AM, Hoai-Thu Vuong <thuv...@gmail.com> wrote: > I would like to counting value in non overlap window, so that I think, I can > do it with same value of window length and slide interval, (note that, this > value is multiple of batch interval). However, nothing is calculated. > > Thanks! > > On Wed Jan 14 2015 at 4:16:27 PM <francois.garil...@typesafe.com> wrote: >> >> Why would you want to ? That would be equivalent to setting your batch >> interval to the same duration you’re suggesting to specify for both window >> length and slide interval, IIUC. >> >> Here’s a nice explanation of windowing by TD : >> https://groups.google.com/forum/#!topic/spark-users/GQoxJHAAtX4 >> >> — >> FG >> >> >> On Wed, Jan 14, 2015 at 9:58 AM, Hoai-Thu Vuong <thuv...@gmail.com> wrote: >>> >>> Could we run spark streaming and reducebywindow with same window length >>> and slide interval? --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
