[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
[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
