This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from a5deb53 MINOR: remove duplicate code of serializing auto-generated
data (#9964)
add 550d8b8 KAFKA-8744: Update Scala API to give names to processors
(#9738)
No new revisions were added by this update.
Summary of changes:
.../streams/scala/kstream/CogroupedKStream.scala | 34 +-
.../streams/scala/kstream/KGroupedStream.scala | 72 +++-
.../streams/scala/kstream/KGroupedTable.scala | 80 +++-
.../kafka/streams/scala/kstream/KStream.scala | 442 +++++++++++++++++++--
.../kafka/streams/scala/kstream/KTable.scala | 407 +++++++++++++++++--
.../kstream/SessionWindowedCogroupedKStream.scala | 24 +-
.../scala/kstream/SessionWindowedKStream.scala | 77 +++-
.../kstream/TimeWindowedCogroupedKStream.scala | 24 +-
.../scala/kstream/TimeWindowedKStream.scala | 77 +++-
.../kafka/streams/scala/kstream/package.scala | 1 +
.../kafka/streams/scala/kstream/KStreamTest.scala | 84 ++++
.../kafka/streams/scala/kstream/KTableTest.scala | 56 ++-
12 files changed, 1245 insertions(+), 133 deletions(-)
