Hi,
Do I understand you correctly, that you just want to have a three different sliding windows (for 3 rules) with duration of 10, 20 and 30 minutes? If so, I haven’t tested it but I would guess that there are at least two solutions for the problem:
1. just create three different sliding windows on top of the same stream (possibly later join/union stream)
2. create sliding window (60 minutes, 10 minutes) and provide custom ReduceFunction/ProcessFunction that splits the records internally into separate aggregations windows. Your reduce function would have a 6 aggregates for 10 minutes intervals for rule1, 3 aggregates for 20 minute intervals and 2 aggregates for 30 minute intervals.
Piotrek
> On 8 Jun 2018, at 21:10, Antonio Saldivar Lezama <
[hidden email]> wrote:
>
> Hello
>
>
> I am wondering if it is possible to process the following scenario, to store all events by event time in a general window and process elements from a smaller time Frame
>
> 1.- Store elements in a General SlidingWindow (60 mins, 10 mins)
> - Rule 1 -> gets 10 mins elements from the general window and get aggregations
> - Rule 2 -> gets 20 mins elements from the general window and get aggregations
> - Rule 3 -> gets 30 mins elements from the general window and get aggregations
> 2.- send results
>
> Thank you
> Regards
Locked
