[
https://issues.apache.org/jira/browse/KAFKA-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15082183#comment-15082183
]
ASF GitHub Bot commented on KAFKA-2653:
---------------------------------------
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/730
KAFKA-2653: Alternative Kafka Streams Stateful API Design
ping @ymatsuda for reviews.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka K2653r
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/730.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 #730
----
commit e46d649c2e40078ed161c83fdc1690456f09f43a
Author: Guozhang Wang <[email protected]>
Date: 2015-12-10T04:31:25Z
v1
commit 2167f29ff630577fe63abc93fd8a58aa6c7d3c1c
Author: Guozhang Wang <[email protected]>
Date: 2015-12-10T19:32:34Z
option 1 of windowing opeartions
commit fb92b2b20f7be6f17c006de6e48cb04065808477
Author: Guozhang Wang <[email protected]>
Date: 2015-12-11T05:47:51Z
v1
commit 0862ec2b4ecb151ea1b3395c74787e4de99891fe
Author: Guozhang Wang <[email protected]>
Date: 2015-12-11T22:15:02Z
v1
commit 9558891bdaccc0b8861f882b957b5131556f896c
Author: Guozhang Wang <[email protected]>
Date: 2015-12-15T00:30:20Z
address Yasu's comments
commit e6373cbc4229637100c97bbb440555c2f0719d03
Author: Guozhang Wang <[email protected]>
Date: 2015-12-15T01:50:17Z
add built-in aggregates
commit 66e122adc8911334e924921bc7fa67275445bd71
Author: Guozhang Wang <[email protected]>
Date: 2015-12-15T03:17:59Z
add built-in aggregates in KTable
commit 13c15ada1edbff51e34022484bcde3955cdf99cd
Author: Guozhang Wang <[email protected]>
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 <[email protected]>
Date: 2015-12-15T19:43:53Z
address Yasu's comments
commit 2b027bf8614026cbec05404dffd5e9c2598db6f4
Author: Guozhang Wang <[email protected]>
Date: 2015-12-15T20:58:11Z
add missing files
commit 5214b12fcd66eb4cfa9af4258ca2146c11aa2e89
Author: Guozhang Wang <[email protected]>
Date: 2015-12-15T23:11:27Z
address Yasu's comments
commit a603a9afde8a86906d085b6cf942df67d2082fb9
Author: Guozhang Wang <[email protected]>
Date: 2015-12-15T23:15:29Z
rename aggregateSupplier to aggregatorSupplier
commit e186710bc3b66e88148ab81087276cedffa2bad3
Author: Guozhang Wang <[email protected]>
Date: 2015-12-16T22:20:59Z
modify built-in aggregates
commit 5bb1e8c95e0c1ab131d5212d1a7d793ce8b49414
Author: Guozhang Wang <[email protected]>
Date: 2015-12-16T22:24:10Z
add missing files
commit 4570dd0d98526f8388c13ef5fe4af12d372f73c6
Author: Guozhang Wang <[email protected]>
Date: 2015-12-17T00:01:58Z
further comments addressed
commit d1ce4b85eff2364a34593cefbe0e8db4070d7fb9
Author: Guozhang Wang <[email protected]>
Date: 2016-01-05T00:53:43Z
Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into
K2653r
commit 13b6b995dff5fef42690852cd5cbb1d3f3b589d4
Author: Guozhang Wang <[email protected]>
Date: 2016-01-05T01:34:41Z
revision v1
----
> 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)
