Guozhang Wang created KAFKA-6567:
------------------------------------
Summary: KStreamWindowReduce can be replaced by
KStreamWindowAggregate
Key: KAFKA-6567
URL: https://issues.apache.org/jira/browse/KAFKA-6567
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Guozhang Wang
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
