Thanks Boyang & Matthias for your replies.
Boyang you are right.. More generically, I want to create a calendar based
window. If my window is in months then the window shall tumble or hop end of
every month. If my window is in days, then the window shall tumble/advanceby
end of every day.
Perhaps, the thread's subject is misleading in the sense that its not dynamic
windows rather calendar based window. Obviously if my unit is days, then my
window size is NOT dynamic.
Thanks
Regards,
Rajesh
On 09/04/19, 10:12 PM, "Boyang Chen" <bche...@outlook.com> wrote:
Hey Rajesh,
my understanding is that you want to create a month-based time window, is
that correct?
Boyang
________________________________
From: Matthias J. Sax <matth...@confluent.io>
Sent: Tuesday, April 9, 2019 11:42 PM
To: dev@kafka.apache.org
Subject: Re: Dynamic window size for aggregations
Feel free to create a feature request JIRA.
For now, you could use a custom processor (via `.transform()`) that uses
an attached window store to implement the logic you need.
-Matthias
On 4/9/19 4:09 AM, Rajesh Kalyanasundaram wrote:
> Hi all,
> We have a requirement to implement aggregations with TimedWindows which
may have varying window sizes. For example, I may want a tumbling window that
tumbles on 31st of Jan and 28th of Feb, 31st of March and so on.
> We did initial analysis of TimedWindows. Found that the windoSize is
being fixed at many places in the streams code.
>
> Any guidance in supporting this would be very much appreciated.
> Thank you.
> Regards,
> Rajesh
> This email and any files transmitted with it are confidential,
proprietary and intended solely for the individual or entity to whom they are
addressed. If you have received this email in error please delete it
immediately.
>
This email and any files transmitted with it are confidential, proprietary and
intended solely for the individual or entity to whom they are addressed. If you
have received this email in error please delete it immediately.
