[ https://issues.apache.org/jira/browse/KAFKA-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062655#comment-15062655 ]
ASF GitHub Bot commented on KAFKA-2653: --------------------------------------- GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/691 KAFKA-2653: Kafka Streams Stateful API Design You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2653 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/691.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 #691 ---- commit e46d649c2e40078ed161c83fdc1690456f09f43a Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-10T04:31:25Z v1 commit 2167f29ff630577fe63abc93fd8a58aa6c7d3c1c Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-10T19:32:34Z option 1 of windowing opeartions commit fb92b2b20f7be6f17c006de6e48cb04065808477 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-11T05:47:51Z v1 commit 0862ec2b4ecb151ea1b3395c74787e4de99891fe Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-11T22:15:02Z v1 commit 9558891bdaccc0b8861f882b957b5131556f896c Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T00:30:20Z address Yasu's comments commit e6373cbc4229637100c97bbb440555c2f0719d03 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T01:50:17Z add built-in aggregates commit 66e122adc8911334e924921bc7fa67275445bd71 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T03:17:59Z add built-in aggregates in KTable commit 13c15ada1edbff51e34022484bcde3955cdf99cd Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T19:28:12Z Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into K2653r commit 1f360a25022d0286f6ebbf1a6735201ba8fdab53 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T19:43:53Z address Yasu's comments commit 2b027bf8614026cbec05404dffd5e9c2598db6f4 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T20:58:11Z add missing files commit 5214b12fcd66eb4cfa9af4258ca2146c11aa2e89 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T23:11:27Z address Yasu's comments commit a603a9afde8a86906d085b6cf942df67d2082fb9 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-15T23:15:29Z rename aggregateSupplier to aggregatorSupplier commit e186710bc3b66e88148ab81087276cedffa2bad3 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-16T22:20:59Z modify built-in aggregates commit 5bb1e8c95e0c1ab131d5212d1a7d793ce8b49414 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-16T22:24:10Z add missing files commit 4570dd0d98526f8388c13ef5fe4af12d372f73c6 Author: Guozhang Wang <wangg...@gmail.com> Date: 2015-12-17T00:01:58Z further comments addressed ---- > Stateful operations in the KStream DSL layer > -------------------------------------------- > > Key: KAFKA-2653 > URL: https://issues.apache.org/jira/browse/KAFKA-2653 > Project: Kafka > Issue Type: Sub-task > Reporter: Guozhang Wang > Assignee: Guozhang Wang > > This includes the interface design the implementation for stateful operations > including: > 0. table representation in KStream. > 1. stream-stream join. > 2. stream-table join. > 3. table-table join. > 4. stream / table aggregations. > With 0 and 3 being tackled in KAFKA-2856 and KAFKA-2962 separately, this > ticket is going to only focus on windowing definition and 1 / 2 / 4 above. -- This message was sent by Atlassian JIRA (v6.3.4#6332)