If you're using event-time windowing you can do something like this:
souce = env.addSource(...)
window1 = source
window2 = window1
And so on...
Does this solve your problem?
> On 17. Feb 2018, at 09:40, Alexandru Gutan <alex.guta...@gmail.com> wrote:
> Dear Carsten,
> Maybe you need a window with multiple triggers.
> On 17 February 2018 at 01:39, Carsten <carsten.muel...@ccmanalysis.de>
>> 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,