You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by KyleWinkelman <gi...@git.apache.org> on 2017/05/04 17:50:45 UTC
[GitHub] kafka pull request #2975: KIP-150 [WIP]: Kafka Streams Cogroup

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 <ky...@optum.com>
Date:   2017-04-14T18:30:36Z

    Initial Cogroup commit.

commit f0fa8c8042c8ca1cfd6e675134a5f02e25789a7f
Author: Kyle Winkelman <ky...@optum.com>
Date:   2017-04-14T18:32:07Z

    Initial Cogroup commit.

commit 6a226d844eff313e0e870f89e93df31aa71f66e2
Author: Kyle Winkelman <wi...@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 <wi...@gmail.com>
Date:   2017-04-20T18:25:46Z

    Update KCogroupedStream to accept a broader range of aggregators.

commit 51e80ee29e479db16a7c49fa8d8fe6b358982e6e
Author: Kyle Winkelman <ky...@optum.com>
Date:   2017-04-20T20:06:39Z

    Fix CRLF.

commit fe6acb70d9dc1adf2246c5ef1cd257a61656798d
Author: Kyle Winkelman <ky...@optum.com>
Date:   2017-04-29T14:44:24Z

    Added Integration Test.

commit 611d3c184546c57b1d325dda57d6afce2eeb30a5
Author: Kyle Winkelman <ky...@optum.com>
Date:   2017-05-01T20:10:02Z

    Add support for SessionWindow and Window aggregations.

commit 702a8a1b584062d4657ac574dfa0ac9b829a947b
Author: Kyle Winkelman <ky...@optum.com>
Date:   2017-05-03T01:45:54Z

    Finish KStreamCogroupIntegrationTest.

commit 99b101222bf38c53734df1e53546445bddfed690
Author: Kyle Winkelman <ky...@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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---