You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Antony Stubbs (Jira)" <ji...@apache.org> on 2020/08/17 11:37:00 UTC
[jira] [Updated] (KAFKA-10408) Calendar based windows
[ https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Antony Stubbs updated KAFKA-10408:
----------------------------------
Description:
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]
was:
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
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
> 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
>
> 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)