[ https://issues.apache.org/jira/browse/KAFKA-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15109381#comment-15109381 ]
ASF GitHub Bot commented on KAFKA-3121: --------------------------------------- GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/795 KAFKA-3121: Remove aggregatorSupplier and add Reduce functions You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K3121s1 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/795.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #795 ---- commit 10837b24c7a8af0e2843a8ae2102610dc28aff3c Author: Guozhang Wang <wangg...@gmail.com> Date: 2016-01-20T02:48:07Z refactor aggregate and add reduce commit c8fe67f78809276b2c9aa3ca4f36d64b79483c1a Author: Guozhang Wang <wangg...@gmail.com> Date: 2016-01-20T06:48:19Z add new files commit ad90555eee8ce7de799a258c175522a95cafb372 Author: Guozhang Wang <wangg...@gmail.com> Date: 2016-01-20T20:52:24Z KAFKA-3121: Remove AggregateSupplier for aggregate and add reduce functions ---- > KStream DSL API Improvement > --------------------------- > > Key: KAFKA-3121 > URL: https://issues.apache.org/jira/browse/KAFKA-3121 > Project: Kafka > Issue Type: Sub-task > Reporter: Guozhang Wang > Assignee: Guozhang Wang > > From some collected feedbacks, here is a list of potential improvements that > we want to make: > 1. Remove AggregateSupplier for aggregate, and provide more built-in > aggregations. > 2. Join to return KeyValue<>. > 3. "Windows" class syntax-sugers. > 4. Add print() to KTable / KStream. > 5. flatMap / flatMapValues to return arrays in addition to Iterable. > 6. make the API function names aligned with Java 8+, e.g. filterOut -> > filterNot > 7. collapse process() and transform() in KStream. > 8. validate Streaming configs and allow passing properties to KafkaStreaming. > 9. Rename KafkaStreaming to Streams. > Also move some of the state package into internals, and create a new > top-level common folder with KeyValue / etc in it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)