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%)
