GitHub user KyleWinkelman opened a pull request:
https://github.com/apache/kafka/pull/2975
KIP-150 [WIP]: Kafka Streams Cogroup
Work in progress PR for KIP-150.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/KyleWinkelman/kafka cogroup
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2975.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 #2975
----
commit 143e5d6852d8baa38a256fb514d2623e9721a28b
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-04-14T18:30:36Z
Initial Cogroup commit.
commit f0fa8c8042c8ca1cfd6e675134a5f02e25789a7f
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-04-14T18:32:07Z
Initial Cogroup commit.
commit 6a226d844eff313e0e870f89e93df31aa71f66e2
Author: Kyle Winkelman <winkelman.k...@gmail.com>
Date: 2017-04-20T18:10:14Z
Remove AbstractKStream from KCogroupedStreamImpl.
Added null checking to KCogroupedStreamImpl and KGroupedStreamImpl.
Added a flag to KCogroupedStreamImpl to prevent additional calls to
cogroup after aggreagate and to prevent multiple aggregate calls.
Update KStreamCogroup to send view calls to one of its parents and
properly handle the Change objects it passes.
commit f39a816cff794bc16c5574e6917cadf35f78cdda
Author: Kyle Winkelman <winkelman.k...@gmail.com>
Date: 2017-04-20T18:25:46Z
Update KCogroupedStream to accept a broader range of aggregators.
commit 51e80ee29e479db16a7c49fa8d8fe6b358982e6e
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-04-20T20:06:39Z
Fix CRLF.
commit fe6acb70d9dc1adf2246c5ef1cd257a61656798d
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-04-29T14:44:24Z
Added Integration Test.
commit 611d3c184546c57b1d325dda57d6afce2eeb30a5
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-05-01T20:10:02Z
Add support for SessionWindow and Window aggregations.
commit 702a8a1b584062d4657ac574dfa0ac9b829a947b
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-05-03T01:45:54Z
Finish KStreamCogroupIntegrationTest.
commit 99b101222bf38c53734df1e53546445bddfed690
Author: Kyle Winkelman <kyle.winkel...@optum.com>
Date: 2017-05-04T01:14:46Z
Improve tests.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
