[
https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10408:
------------------------------------
Labels: needs-kip (was: )
> 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)
