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
