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 6c80643 [KAFKA-8522] Streamline tombstone and transaction marker removal (#10914) add a0c7e6d KAFKA-13216: Use a KV with list serde for the shared store (#11252) No new revisions were added by this update. Summary of changes: .../streams/kstream/internals/KStreamImplJoin.java | 101 +++------ .../kstream/internals/KStreamKStreamJoin.java | 84 +++++--- .../internals/graph/StreamStreamJoinNode.java | 11 +- .../apache/kafka/streams/state/StateSerdes.java | 3 + .../ChangeLoggingListValueBytesStore.java | 62 ++++++ .../streams/state/internals/LeftOrRightValue.java | 2 +- .../streams/state/internals/ListValueStore.java | 166 ++++++++++++++ ...toreBuilder.java => ListValueStoreBuilder.java} | 23 +- .../internals/RocksDBTimeOrderedWindowStore.java | 204 ------------------ .../internals/RocksDbWindowBytesStoreSupplier.java | 15 +- .../streams/state/internals/SessionKeySchema.java | 3 +- .../state/internals/TimeOrderedKeySchema.java | 191 ---------------- .../internals/TimeOrderedWindowStoreBuilder.java | 80 ------- ...oinSide.java => TimestampedKeyAndJoinSide.java} | 33 ++- ... => TimestampedKeyAndJoinSideDeserializer.java} | 28 ++- ...de.java => TimestampedKeyAndJoinSideSerde.java} | 9 +- ...va => TimestampedKeyAndJoinSideSerializer.java} | 16 +- .../streams/state/internals/WindowKeySchema.java | 3 +- .../AbstractRocksDBSegmentedBytesStoreTest.java | 23 +- .../internals/CachingInMemorySessionStoreTest.java | 12 +- .../CachingPersistentSessionStoreTest.java | 14 +- .../CompositeReadOnlyWindowStoreTest.java | 20 +- .../state/internals/ListValueStoreTest.java | 216 +++++++++++++++++++ .../RocksDBTimeOrderedWindowStoreTest.java | 239 --------------------- .../state/internals/TimeOrderedKeySchemaTest.java | 84 -------- ...> TimestampedKeyAndJoinSideSerializerTest.java} | 24 +-- .../org/apache/kafka/test/StreamsTestUtils.java | 9 + 27 files changed, 656 insertions(+), 1019 deletions(-) create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingListValueBytesStore.java create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/ListValueStore.java copy streams/src/main/java/org/apache/kafka/streams/state/internals/{KeyValueStoreBuilder.java => ListValueStoreBuilder.java} (76%) delete mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java delete mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeySchema.java delete mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedWindowStoreBuilder.java rename streams/src/main/java/org/apache/kafka/streams/state/internals/{KeyAndJoinSide.java => TimestampedKeyAndJoinSide.java} (59%) rename streams/src/main/java/org/apache/kafka/streams/state/internals/{KeyAndJoinSideDeserializer.java => TimestampedKeyAndJoinSideDeserializer.java} (59%) rename streams/src/main/java/org/apache/kafka/streams/state/internals/{KeyAndJoinSideSerde.java => TimestampedKeyAndJoinSideSerde.java} (71%) rename streams/src/main/java/org/apache/kafka/streams/state/internals/{KeyAndJoinSideSerializer.java => TimestampedKeyAndJoinSideSerializer.java} (72%) create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/ListValueStoreTest.java delete mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStoreTest.java delete mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedKeySchemaTest.java rename streams/src/test/java/org/apache/kafka/streams/state/internals/{KeyAndJoinSideSerializerTest.java => TimestampedKeyAndJoinSideSerializerTest.java} (65%)