You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/08/22 01:30:42 UTC
[kafka] branch trunk updated (c8453e9 -> 89d0678)
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 c8453e9 KAFKA-10316: Consider renaming getter method for Interactive Queries (#9146)
add 89d0678 KAFKA-9929: Support reverse iterator on KeyValueStore (#9137)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractReadOnlyDecorator.java | 12 ++
.../internals/AbstractReadWriteDecorator.java | 11 ++
.../apache/kafka/streams/state/KeyValueStore.java | 4 +-
.../kafka/streams/state/ReadOnlyKeyValueStore.java | 53 +++++--
.../AbstractMergedSortedCacheStoreIterator.java | 69 +++++++--
.../AbstractRocksDBSegmentedBytesStore.java | 5 +-
.../state/internals/CachingKeyValueStore.java | 38 ++++-
.../state/internals/CachingSessionStore.java | 5 +-
.../state/internals/CachingWindowStore.java | 5 +-
.../internals/ChangeLoggingKeyValueBytesStore.java | 11 ++
.../state/internals/CompositeKeyValueIterator.java | 3 +-
.../internals/CompositeReadOnlyKeyValueStore.java | 47 +++++-
.../state/internals/InMemoryKeyValueStore.java | 51 +++++--
.../state/internals/InMemorySessionStore.java | 5 +-
.../state/internals/InMemoryWindowStore.java | 5 +-
...ValueToTimestampedKeyValueByteStoreAdapter.java | 11 ++
.../streams/state/internals/MemoryLRUCache.java | 16 ++
.../state/internals/MemoryNavigableLRUCache.java | 28 +++-
...ergedSortedCacheKeyValueBytesStoreIterator.java | 8 +-
.../MergedSortedCacheSessionStoreIterator.java | 2 +-
.../MergedSortedCacheWindowStoreIterator.java | 2 +-
...rgedSortedCacheWindowStoreKeyValueIterator.java | 2 +-
.../state/internals/MeteredKeyValueStore.java | 15 ++
.../kafka/streams/state/internals/NamedCache.java | 20 ++-
.../internals/ReadOnlyKeyValueStoreFacade.java | 11 ++
.../state/internals/RocksDBPrefixIterator.java | 54 -------
.../state/internals/RocksDBRangeIterator.java | 40 +++--
.../streams/state/internals/RocksDBStore.java | 52 +++++--
.../state/internals/RocksDBTimestampedStore.java | 105 +++++++++----
.../streams/state/internals/RocksDbIterator.java | 8 +-
.../kafka/streams/state/internals/ThreadCache.java | 24 ++-
.../internals/TimestampedKeyValueStoreBuilder.java | 11 ++
.../state/internals/AbstractKeyValueStoreTest.java | 140 ++++++++++++++++-
.../internals/AbstractSessionBytesStoreTest.java | 17 ++-
.../internals/AbstractWindowBytesStoreTest.java | 35 ++---
.../state/internals/CachingKeyValueStoreTest.java | 154 ++++++++++++++-----
.../state/internals/CachingSessionStoreTest.java | 3 +-
.../state/internals/CachingWindowStoreTest.java | 6 +-
.../CompositeReadOnlyKeyValueStoreTest.java | 168 +++++++++++++++------
.../state/internals/InMemoryKeyValueStoreTest.java | 6 +-
...dSortedCacheKeyValueBytesStoreIteratorTest.java | 98 +++++++++---
.../state/internals/RocksDBKeyValueStoreTest.java | 6 +-
.../streams/state/internals/RocksDBStoreTest.java | 6 +-
.../internals/RocksDBTimestampedStoreTest.java | 65 ++++++++
44 files changed, 1096 insertions(+), 341 deletions(-)
delete mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBPrefixIterator.java