You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2021/02/05 00:25:21 UTC
[kafka] branch trunk updated (d98df7f -> 5552da3)
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 d98df7f MINOR: Add KafkaEventQueue (#10030)
add 5552da3 KAFKA-5488: Add type-safe split() operator (#9107)
No new revisions were added by this update.
Summary of changes:
docs/streams/developer-guide/dsl-api.html | 34 ++--
docs/upgrade.html | 6 +
.../org/apache/kafka/streams/kstream/Branched.java | 148 ++++++++++++++++++
.../kafka/streams/kstream/BranchedKStream.java | 171 +++++++++++++++++++++
.../org/apache/kafka/streams/kstream/KStream.java | 26 +++-
.../apache/kafka/streams/kstream/Predicate.java | 2 +-
.../{JoinedInternal.java => BranchedInternal.java} | 34 ++--
.../kstream/internals/BranchedKStreamImpl.java | 119 ++++++++++++++
.../streams/kstream/internals/KStreamBranch.java | 22 ++-
.../streams/kstream/internals/KStreamImpl.java | 19 ++-
.../apache/kafka/streams/StreamsBuilderTest.java | 18 ++-
.../kstream/internals/KStreamBranchTest.java | 4 +-
.../streams/kstream/internals/KStreamImplTest.java | 12 +-
.../kstream/internals/KStreamSplitTest.java | 143 +++++++++++++++++
.../kstream/internals/graph/StreamsGraphTest.java | 55 +++----
.../kafka/streams/scala/kstream/Branched.scala | 67 ++++++++
.../streams/scala/kstream/BranchedKStream.scala | 116 ++++++++++++++
.../kafka/streams/scala/kstream/KStream.scala | 31 ++--
.../kafka/streams/scala/kstream/package.scala | 1 +
.../streams/scala/kstream/KStreamSplitTest.scala | 126 +++++++++++++++
20 files changed, 1067 insertions(+), 87 deletions(-)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/Branched.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/BranchedKStream.java
copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/{JoinedInternal.java => BranchedInternal.java} (56%)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/BranchedKStreamImpl.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSplitTest.java
create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Branched.scala
create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/BranchedKStream.scala
create mode 100644 streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/KStreamSplitTest.scala