This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 3805f37 KAFKA-12574: KIP-732, Deprecate eos-alpha and replace
eos-beta with eos-v2 (#10573)
add bf359f8 KAFKA-10847: Fix spurious results on left/outer stream-stream
joins (#10462)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 4 +-
.../streams/kstream/internals/KStreamImpl.java | 2 +
.../streams/kstream/internals/KStreamImplJoin.java | 116 ++++-
.../kstream/internals/KStreamKStreamJoin.java | 113 ++++-
.../internals/graph/StreamStreamJoinNode.java | 18 +-
.../streams/state/internals/KeyAndJoinSide.java | 81 ++++
.../internals/KeyAndJoinSideDeserializer.java | 66 +++
...imestampSerde.java => KeyAndJoinSideSerde.java} | 13 +-
.../state/internals/KeyAndJoinSideSerializer.java | 69 +++
.../streams/state/internals/LeftOrRightValue.java | 113 +++++
.../internals/LeftOrRightValueDeserializer.java | 74 ++++
...estampSerde.java => LeftOrRightValueSerde.java} | 17 +-
.../internals/LeftOrRightValueSerializer.java | 88 ++++
.../internals/TimeOrderedWindowStoreBuilder.java | 4 -
.../apache/kafka/streams/StreamsBuilderTest.java | 13 +-
.../org/apache/kafka/streams/TopologyTest.java | 259 +++++++++++
.../StreamStreamJoinIntegrationTest.java | 8 +-
.../KStreamImplValueJoinerWithKeyTest.java | 6 +-
.../kstream/internals/KStreamKStreamJoinTest.java | 13 +-
.../internals/KStreamKStreamLeftJoinTest.java | 429 ++++++++++++++++--
...nTest.java => KStreamKStreamOuterJoinTest.java} | 477 +++++++++++++++++++--
.../internals/KeyAndJoinSideSerializerTest.java | 72 ++++
.../internals/LeftOrRightValueSerializerTest.java | 78 ++++
23 files changed, 2012 insertions(+), 121 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyAndJoinSide.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyAndJoinSideDeserializer.java
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{ValueAndTimestampSerde.java
=> KeyAndJoinSideSerde.java} (66%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyAndJoinSideSerializer.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValue.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValueDeserializer.java
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{ValueAndTimestampSerde.java
=> LeftOrRightValueSerde.java} (61%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValueSerializer.java
copy
streams/src/test/java/org/apache/kafka/streams/kstream/internals/{KStreamKStreamLeftJoinTest.java
=> KStreamKStreamOuterJoinTest.java} (56%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/KeyAndJoinSideSerializerTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/LeftOrRightValueSerializerTest.java
