[KAFKA-6567] KStreamWindowReduce can be replaced by KStreamWindowAggregate

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: streams
• Labels: newbie
• Assignee: Samuel Hawker
• Reporter: Guozhang Wang
• Created: 15/Feb/18 21:52
• Updated: 20/Nov/18 05:28
• Resolved: 20/Nov/18 05:28

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.

Issue Links

• links to: GitHub Pull Request #5922