Hi Carsten, If you're using event-time windowing you can do something like this:
souce = env.addSource(...) window1 = source .keyBy() .window(10 sec) .aggregate()/reduce() window1.addSink(...) window2 = window1 .keyBy() .windwo(30 sec) .aggregate()/reduce() window2.addSink(...) And so on... Does this solve your problem? Best, Aljoscha > On 17. Feb 2018, at 09:40, Alexandru Gutan <alex.guta...@gmail.com> wrote: > > Dear Carsten, > > Maybe you need a window with multiple triggers. > > Best, > Alex. > > On 17 February 2018 at 01:39, Carsten <carsten.muel...@ccmanalysis.de> > wrote: > >> Hello all, >> >> for some of our sensor data we would like to aggregate data for 10sec, >> 30sec, 1 min etc., thus conceptually have multiple windows on a single >> stream. Currently, I am simply duplicating the data stream (separate >> execution environments etc) and process each of the required windows. Is >> there a better way? I heard about cascading windows but I am not sure if >> this approach exits, needs to implemented from scratch, or how to use it. >> >> >> Any link/hint/suggestion, would be greatly appreciated. >> >> >> Have a great day, >> >> Carsten >>
