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 (5b829f2 -> 6925775)
Date Thu, 03 Oct 2019 03:32:39 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 5b829f2  KAFKA-8447: New Metric to Measure Number of Tasks on a Connector (#6843)
     add 6925775  KAFKA-8558:  Add StreamJoined config object to join (#7285)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/kstream/KStream.java  | 279 +++++++++++++++++++-
 .../apache/kafka/streams/kstream/StreamJoined.java | 287 +++++++++++++++++++++
 .../streams/kstream/internals/KStreamImpl.java     | 237 ++++++-----------
 .../streams/kstream/internals/KStreamImplJoin.java | 214 +++++++++++++++
 ...inedInternal.java => StreamJoinedInternal.java} |  31 ++-
 .../InMemoryWindowBytesStoreSupplier.java          |  10 +
 .../apache/kafka/streams/StreamsBuilderTest.java   | 145 ++++++++---
 .../RepartitionOptimizingIntegrationTest.java      |   4 +-
 .../StreamStreamJoinIntegrationTest.java           |  38 +++
 .../kstream/RepartitionTopicNamingTest.java        |   2 +-
 .../streams/kstream/internals/KStreamImplTest.java |  28 +-
 .../kstream/internals/KStreamKStreamJoinTest.java  | 210 ++++++++++++++-
 .../internals/KStreamKStreamLeftJoinTest.java      |   8 +-
 .../kafka/streams/tests/StreamsOptimizedTest.java  |   4 +-
 .../kafka/streams/scala/ImplicitConversions.scala  |   5 +
 .../kafka/streams/scala/kstream/KStream.scala      |  36 +--
 .../kafka/streams/scala/kstream/StreamJoined.scala |  90 +++++++
 .../kafka/streams/scala/kstream/package.scala      |   1 +
 .../apache/kafka/streams/scala/TopologyTest.scala  |  10 +-
 .../streams/scala/kstream/StreamJoinedTest.scala   |  69 +++++
 20 files changed, 1443 insertions(+), 265 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
 copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/{JoinedInternal.java
=> StreamJoinedInternal.java} (61%)
 create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala
 create mode 100644 streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/StreamJoinedTest.scala


Mime
View raw message