kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (8b57f6c -> dd8af2b)
Date Sun, 15 Dec 2019 19:45:00 GMT
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%)


Mime
View raw message