[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180882#comment-17180882
]
Matthias J. Sax commented on KAFKA-10408:
-----------------------------------------
Another example implementation is this one:
[https://github.com/confluentinc/kafka-streams-examples/blob/5.5.0-post/src/test/java/io/confluent/examples/streams/window/DailyTimeWindows.java]
> Calendar based windows
> ----------------------
>
> Key: KAFKA-10408
> URL: https://issues.apache.org/jira/browse/KAFKA-10408
> Project: Kafka
> Issue Type: New Feature
> Components: streams
> Affects Versions: 2.6.0
> Reporter: Antony Stubbs
> Priority: Minor
> Labels: needs-kip
>
> A date based window, for example aggregate all payments made until each month
> date of the 15th, or all payments made each year until April 1st.
> Should handle time zones "properly", e.g. allow user to specify which time
> zone to base it on.
> Also should support setting a time cut off, and just simply "midnight" in the
> given zone. (.e.g 6pm April 15th).
> Ideally will also support day offsets, e.g. last day of every month, first
> Tuesday of each week, last Friday of the month.
> Example implementation of a specific aggregator, with a window implementation
> implicitly embedded:
> [https://github.com/astubbs/ks-tributary/blob/denormalisation-base-cp-libs/streams-module/src/main/java/io/confluent/ps/streams/processors/YearlyAggregator.java]
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
