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)

Reply via email to