Well, it has been +1'd in our heads. ;) We will keep this in mind. TD
On Thu, Feb 27, 2014 at 7:45 AM, Adrian Mocanu <amoc...@verticalscope.com>wrote: > If there is somewhere I can +1 this feature let me know. > > > > My use case is for financial indicators (math formulas) and a lot of them > go by window count like moving average. > > > > Thanks > > A > > > > *From:* Tathagata Das [mailto:tathagata.das1...@gmail.com] > *Sent:* February-26-14 2:05 PM > *To:* user@spark.apache.org > *Cc:* u...@spark.incubator.apache.org > *Subject:* Re: window every n elements instead of time based > > > > 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 > > > > >
