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%)
