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 (03da52e -> 1ccca5c)
Date Wed, 08 Jan 2020 23:29:46 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 03da52e  MINOR: Set MaxInlineLevel to 15 (#7811)
     add 1ccca5c  KAFKA-6049: extend Kafka Streams Scala API for cogroup (KIP-150) (#7847)

No new revisions were added by this update.

Summary of changes:
 .../kafka/streams/kstream/CogroupedKStream.java    |  20 ++--
 .../kstream/TimeWindowedCogroupedKStream.java      |   2 -
 .../kafka/streams/scala/ImplicitConversions.scala  |  24 ++++-
 .../streams/scala/kstream/CogroupedKStream.scala   |  73 ++++++++++++++
 .../streams/scala/kstream/KGroupedStream.scala     |  10 ++
 .../kstream/SessionWindowedCogroupedKStream.scala  |  48 +++++++++
 .../kstream/TimeWindowedCogroupedKStream.scala     |  48 +++++++++
 .../apache/kafka/streams/scala/TopologyTest.scala  | 111 ++++++++++++++++++---
 .../kafka/streams/scala/kstream/ConsumedTest.scala |   2 +-
 .../kafka/streams/scala/kstream/GroupedTest.scala  |   3 +-
 .../kafka/streams/scala/kstream/JoinedTest.scala   |   2 +-
 .../kafka/streams/scala/kstream/KStreamTest.scala  |   2 +-
 .../streams/scala/kstream/MaterializedTest.scala   |   2 +-
 .../kafka/streams/scala/kstream/ProducedTest.scala |   2 +-
 .../streams/scala/kstream/StreamJoinedTest.scala   |   3 +-
 .../streams/scala/kstream/SuppressedTest.scala     |   1 +
 16 files changed, 315 insertions(+), 38 deletions(-)
 create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/CogroupedKStream.scala
 create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedCogroupedKStream.scala
 create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedCogroupedKStream.scala


Mime
View raw message