This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 1bf418b MINOR: Pass along compression type to snapshot writer (#11556)
add 62f73c3 KAFKA-13498: track position in remaining state stores (#11541)
No new revisions were added by this update.
Summary of changes:
.../state/internals/CachingKeyValueStore.java | 8 ++++++
.../state/internals/InMemorySessionStore.java | 23 ++++++++++++++++
.../state/internals/InMemoryWindowStore.java | 23 ++++++++++++++++
.../kafka/streams/state/internals/Position.java | 10 ++++---
.../state/internals/RocksDBSessionStore.java | 22 +++++++++++++++
.../state/internals/RocksDBWindowStore.java | 24 ++++++++++++++++
.../internals/AbstractSessionBytesStoreTest.java | 2 +-
.../CachingInMemoryKeyValueStoreTest.java | 23 ++++++++++++++++
.../state/internals/InMemorySessionStoreTest.java | 32 ++++++++++++++++++++++
.../state/internals/InMemoryWindowStoreTest.java | 31 +++++++++++++++++++++
.../internals/MonotonicProcessorRecordContext.java | 16 ++++++++++-
.../state/internals/RocksDBSessionStoreTest.java | 31 +++++++++++++++++++++
.../state/internals/RocksDBWindowStoreTest.java | 30 ++++++++++++++++++++
13 files changed, 269 insertions(+), 6 deletions(-)
