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 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
