kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch trunk updated (b403561 -> beac4c7)
Date Mon, 23 Sep 2019 17:12:35 GMT
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 b403561  KAFKA-8086: Use 1 partition for offset topic when possible (#7356)
     add beac4c7  KAFKA-6958: Overload methods for group and windowed stream to allow to name
operation name using the new Named class (#6413)

No new revisions were added by this update.

Summary of changes:
 .../kafka/streams/kstream/KGroupedStream.java      | 200 ++++++++++++++
 .../kafka/streams/kstream/KGroupedTable.java       | 307 +++++++++++++++++++++
 .../streams/kstream/SessionWindowedKStream.java    | 259 +++++++++++++++++
 .../kafka/streams/kstream/TimeWindowedKStream.java | 278 +++++++++++++++++++
 .../internals/GroupedStreamAggregateBuilder.java   |   4 +-
 .../kstream/internals/InternalStreamsBuilder.java  |  26 +-
 .../kstream/internals/KGroupedStreamImpl.java      |  46 ++-
 .../kstream/internals/KGroupedTableImpl.java       |  77 ++++--
 .../internals/SessionWindowedKStreamImpl.java      |  63 ++++-
 .../kstream/internals/TimeWindowedKStreamImpl.java |  63 ++++-
 .../apache/kafka/streams/StreamsBuilderTest.java   |  24 +-
 .../internals/SessionWindowedKStreamImplTest.java  |  13 +-
 .../internals/TimeWindowedKStreamImplTest.java     |  14 +-
 13 files changed, 1320 insertions(+), 54 deletions(-)


Mime
View raw message