Currently, all in-built DStream operation is time-based windowing. We may provide count-based windowing in the future.
On Wed, Feb 26, 2014 at 9:34 AM, Adrian Mocanu <amoc...@verticalscope.com>wrote: > Hi > > Is there a way to do window processing but not based on time but every 6 > items going through the stream? > > > > Example: > > Window of size 3 with 1 item "duration" > > Stream data: 1,2,3,4,5,6,7 > > [1,2,3]=window 1 > > [2,3,4]=window 2 > > [3,4,5]=window 2 > > etc > > > > -Adrian > > >
