Guozhang Wang created KAFKA-3337: ------------------------------------ Summary: Extract selector as a separate groupBy operator for KTable aggregations Key: KAFKA-3337 URL: https://issues.apache.org/jira/browse/KAFKA-3337 Project: Kafka Issue Type: Sub-task Reporter: Guozhang Wang Priority: Blocker Fix For: 0.10.0.0
Currently KTable aggregation takes a selector and an aggregator, which makes the function a little bit "heavy". It is better to extract the selector in a separate groupBy function such that {code} table.groupBy(selector).aggregate(aggregator); {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)