You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by mj...@apache.org on 2019/12/15 19:45:00 UTC

[kafka] branch trunk updated (8b57f6c -> dd8af2b)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 8b57f6c  KAFKA-6049: Add auto-repartitioning for cogroup (#7792)
     add dd8af2b  KAFKA-6049: Add session window support for cogroup (#7782)

No new revisions were added by this update.

Summary of changes:
 .../kafka/streams/kstream/CogroupedKStream.java    |   8 +
 .../kstream/SessionWindowedCogroupedKStream.java   | 159 +++++++++++++
 .../kstream/internals/CogroupedKStreamImpl.java    |  14 ++
 .../SessionWindowedCogroupedKStreamImpl.java       | 150 ++++++++++++
 .../TimeWindowedCogroupedKStreamImpl.java          |   9 +-
 .../internals/CogroupedKStreamImplTest.java        |  12 +-
 ...> SessionWindowedCogroupedKStreamImplTest.java} | 261 ++++++++++++---------
 .../TimeWindowedCogroupedKStreamImplTest.java      |  26 +-
 8 files changed, 517 insertions(+), 122 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java
 copy streams/src/test/java/org/apache/kafka/streams/kstream/internals/{TimeWindowedCogroupedKStreamImplTest.java => SessionWindowedCogroupedKStreamImplTest.java} (61%)