Windowing and Aggregation across windows

[saket kothari <sa...@gmail.com>]

Does aggregation happen per window..what if I want to use the agg result of
a prev window on the next window?Is it possible?

I have a one second window  with grace period 5 mins..
When my first window expires , it will have some aggregate value and store
it to another topic.
Now, when my second window expires, I want it to add the first window aggr
+ second window agg and then store it in another topic.

Similarly when my third window expires, I want to add its own aggr +
overall agg till now(here, 1st window + 2nd window) and then store in
another topic.

Is this possible in kafka streams?

Also will window expiration occur in the same order?Like 1st window expires
first, then second,then third and so on..


Thanks and Regards

Saket

Re: Windowing and Aggregation across windows

[saket kothari <sa...@gmail.com>]

Can someone please help here?


Thanks and Regards
Saket

On Fri, Apr 30, 2021 at 8:31 PM saket kothari <sa...@gmail.com> wrote:

> Does aggregation happen per window..what if I want to use the agg result
> of a prev window on the next window?Is it possible?
>
> I have a one second window  with grace period 5 mins..
> When my first window expires , it will have some aggregate value and store
> it to another topic.
> Now, when my second window expires, I want it to add the first window aggr
> + second window agg and then store it in another topic.
>
> Similarly when my third window expires, I want to add its own aggr +
> overall agg till now(here, 1st window + 2nd window) and then store in
> another topic.
>
> Is this possible in kafka streams?
>
> Also will window expiration occur in the same order?Like 1st window
> expires first, then second,then third and so on..
>
>
> Thanks and Regards
>
> Saket
>