You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Amsterdam Luís de Lima Filho <am...@gmail.com> on 2023/01/18 14:33:50 UTC
Tumbling windows offset
Hello everyone,
I need to perform windowed aggregation for weekly interval, from Monday to Monday, using Tumbling Windows.
It does not seem to be supported: https://stackoverflow.com/questions/72785744/how-to-apply-an-offset-to-tumbling-window-in-order-to-delay-the-starting-of-win
Can someone help me with a workaround or guidance on how to make a PR adding this feature?
I need this to finish a migration from Flink to Kafka Streams in prod.
Best,
Amsterdam
Re: Tumbling windows offset
Posted by Amsterdam Luís de Lima Filho <am...@gmail.com>.
Thanks!
> On 19. Jan 2023, at 00:45, Matthias J. Sax <mj...@apache.org> wrote:
>
> You can use a custom window implementation to do this.
>
> Cf https://github.com/confluentinc/kafka-streams-examples/blob/7.1.1-post/src/test/java/io/confluent/examples/streams/window/DailyTimeWindows.java
>
>
> -Matthias
>
> On 1/18/23 6:33 AM, Amsterdam Luís de Lima Filho wrote:
>> Hello everyone,
>> I need to perform windowed aggregation for weekly interval, from Monday to Monday, using Tumbling Windows.
>> It does not seem to be supported: https://stackoverflow.com/questions/72785744/how-to-apply-an-offset-to-tumbling-window-in-order-to-delay-the-starting-of-win
>> Can someone help me with a workaround or guidance on how to make a PR adding this feature?
>> I need this to finish a migration from Flink to Kafka Streams in prod.
>> Best,
>> Amsterdam
Re: Tumbling windows offset
Posted by "Matthias J. Sax" <mj...@apache.org>.
You can use a custom window implementation to do this.
Cf
https://github.com/confluentinc/kafka-streams-examples/blob/7.1.1-post/src/test/java/io/confluent/examples/streams/window/DailyTimeWindows.java
-Matthias
On 1/18/23 6:33 AM, Amsterdam Luís de Lima Filho wrote:
> Hello everyone,
>
> I need to perform windowed aggregation for weekly interval, from Monday to Monday, using Tumbling Windows.
>
> It does not seem to be supported: https://stackoverflow.com/questions/72785744/how-to-apply-an-offset-to-tumbling-window-in-order-to-delay-the-starting-of-win
>
> Can someone help me with a workaround or guidance on how to make a PR adding this feature?
>
> I need this to finish a migration from Flink to Kafka Streams in prod.
>
> Best,
> Amsterdam