Ya the window duration is how large the window is, the slide duration is how much the window slides each time.
So let's say the underlying stream has the following batches: 1 2 3 4 5 6 7 8 9 Now lets say you have: window=3 slide=1 [1 2 3] 4 5 6 7 8 9 1 [2 3 4] 5 6 7 8 9 1 2 [3 4 5] 6 7 8 9 1 2 3 [4 5 6] 7 8 9 window=3 slide=2 [1 2 3] 4 5 6 7 8 9 1 2 [3 4 5] 6 7 8 9 1 2 3 4 [5 6 7] 8 9 1 2 3 4 5 6 [7 8 9] window=3 slide=3 [1 2 3] 4 5 6 7 8 9 1 2 3 [4 5 6] 7 8 9 1 2 3 4 5 6 [7 8 9] On Fri, Nov 1, 2013 at 7:04 AM, dachuan <[email protected]> wrote: > they are in streaming.dstream.WindowDStream. > > thanks.
