You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2021/09/16 23:46:31 UTC
[kafka] branch trunk updated (6c80643 -> a0c7e6d)
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%)