Hi, I also had this suspicion in the past. The sliding pre reducers are horribly slow. For example, this code:
ds.window(...).every(...).mapWindow(new MyWindowMapReducer()) is a lot faster than this: ds.window(...).every(...).reduceWindow(new MyWindowReducer()) We are currently working on this for the next release (0.10). On Thu, 30 Jul 2015 at 11:54 MaGuoWei <[email protected]> wrote: > hi till > I mean the branch of the if statement is never execute. > thanks > > 发自我的 iPhone > > > 在 2015年7月30日，下午5:51，Till Rohrmann <[email protected]> 写道： > > > > Hi MaGuoWei, > > > > do you mean that the branch of the if statement (line 130) is never > > executed? Or are you looking for an example which uses the > SlidingPreReducer > > ? > > > > Cheers, > > Till > > > > > >> On Thu, Jul 30, 2015 at 11:33 AM, MaGuoWei <[email protected]> > wrote: > >> > >> hi guysThere is a function updateCurrent() in this > >> class(SlidingPreReducer).I think there is no chance to run the following > >> code in this function:currentReduced = > >> reducer.reduce(serializer.copy(currentReduced), element);Can any one > give > >> me a example that can run this code. (I have already see all the test > >> case)thanks a lot > >> >
