is developed?
Boyang
From: Rajesh Kalyanasundaram
Sent: Wednesday, April 10, 2019 1:05 AM
To: dev@kafka.apache.org
Subject: Re: Dynamic window size for aggregations
Thanks Boyang & Matthias for your replies.
Boyang you are right.. More generically, I want to c
tanding is that you want to create a month-based time window, is
that correct?
Boyang
From: Matthias J. Sax
Sent: Tuesday, April 9, 2019 11:42 PM
To: dev@kafka.apache.org
Subject: Re: Dynamic window size for aggregations
Feel free
Hey Rajesh,
my understanding is that you want to create a month-based time window, is that
correct?
Boyang
From: Matthias J. Sax
Sent: Tuesday, April 9, 2019 11:42 PM
To: dev@kafka.apache.org
Subject: Re: Dynamic window size for aggregations
Feel free to
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 w
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
