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