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 2020/09/02 22:18:20 UTC
[kafka] branch trunk updated (4662ed4 -> 4f06d9e)
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 4662ed4 MINOR: Fix build scala 2.12 build after KAFKA-10020 (#9245)
add 4f06d9e KAFKA-9929: Support backward iterator on WindowStore (#9138)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractReadOnlyDecorator.java | 36 ++-
.../internals/AbstractReadWriteDecorator.java | 32 ++-
.../kafka/streams/state/ReadOnlyWindowStore.java | 173 ++++++++++----
.../apache/kafka/streams/state/WindowStore.java | 115 ++++++---
.../AbstractMergedSortedCacheStoreIterator.java | 1 -
.../AbstractRocksDBSegmentedBytesStore.java | 82 ++++++-
.../streams/state/internals/AbstractSegments.java | 29 ++-
.../state/internals/CachingWindowStore.java | 241 +++++++++++++++----
.../internals/ChangeLoggingWindowBytesStore.java | 31 ++-
.../internals/CompositeReadOnlyWindowStore.java | 112 +++++++--
.../state/internals/InMemoryWindowStore.java | 177 +++++++++++---
.../MergedSortedCacheWindowStoreIterator.java | 5 +-
...rgedSortedCacheWindowStoreKeyValueIterator.java | 5 +-
.../state/internals/MeteredWindowStore.java | 48 +++-
.../state/internals/ReadOnlyWindowStoreFacade.java | 58 +++--
.../state/internals/RocksDBTimestampedStore.java | 1 -
.../state/internals/RocksDBWindowStore.java | 36 ++-
.../kafka/streams/state/internals/Segment.java | 4 -
.../streams/state/internals/SegmentIterator.java | 19 +-
.../state/internals/SegmentedBytesStore.java | 37 ++-
.../kafka/streams/state/internals/Segments.java | 4 +-
.../streams/state/internals/SessionKeySchema.java | 5 +-
.../internals/TimestampedWindowStoreBuilder.java | 42 +++-
.../streams/state/internals/WindowKeySchema.java | 9 +-
.../WindowToTimestampedWindowByteStoreAdapter.java | 74 ++++--
.../kafka/streams/kstream/SessionWindowsTest.java | 9 +-
.../kafka/streams/state/NoOpWindowStore.java | 45 +++-
.../state/internals/AbstractKeyValueStoreTest.java | 29 +--
.../internals/AbstractWindowBytesStoreTest.java | 188 ++++++++++++---
.../state/internals/CachingWindowStoreTest.java | 234 ++++++++++++++++--
.../ChangeLoggingWindowBytesStoreTest.java | 25 +-
.../CompositeReadOnlyWindowStoreTest.java | 264 +++++++++++++++++----
.../DelegatingPeekingKeyValueIteratorTest.java | 19 +-
.../state/internals/InMemoryWindowStoreTest.java | 25 +-
.../state/internals/KeyValueSegmentsTest.java | 41 +++-
...dSortedCacheWrappedWindowStoreIteratorTest.java | 106 ++++++++-
...acheWrappedWindowStoreKeyValueIteratorTest.java | 76 +++++-
.../state/internals/MeteredWindowStoreTest.java | 11 +-
.../state/internals/ReadOnlyWindowStoreStub.java | 207 +++++++++++++---
.../state/internals/SegmentIteratorTest.java | 88 +++++--
.../streams/state/internals/ThreadCacheTest.java | 10 +-
.../TimestampedKeyValueStoreBuilderTest.java | 21 +-
.../state/internals/TimestampedSegmentsTest.java | 41 +++-
.../TimestampedWindowStoreBuilderTest.java | 17 +-
.../state/internals/WindowKeySchemaTest.java | 64 ++---
.../apache/kafka/test/SegmentedBytesStoreStub.java | 112 ---------
.../org/apache/kafka/test/StreamsTestUtils.java | 7 +-
.../kafka/streams/internals/WindowStoreFacade.java | 25 ++
48 files changed, 2367 insertions(+), 673 deletions(-)
delete mode 100644 streams/src/test/java/org/apache/kafka/test/SegmentedBytesStoreStub.java