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:23:00 UTC

[jira] [Created] (KAFKA-10408) Calendar based windows

Antony Stubbs created KAFKA-10408:
-------------------------------------

             Summary: 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
            Assignee: Bruno Cadonna


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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)