Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6567

KStreamWindowReduce can be replaced by KStreamWindowAggregate

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.2.0
    • Component/s: streams
    • Labels:

      Description

      This is a tech debt worth cleaning up: KStreamWindowReduce should be able to be replaced by KStreamWindowAggregate. In fact, we have already done this for session windows, where in SessionWindowedKStreamImpl we use reduceInitializer, aggregatorForReducer and mergerForAggregator to replace reducer with aggregator.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Samuel Hawker Samuel Hawker
                Reporter:
                guozhang Guozhang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                8 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: