kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (4662ed4 -> 4f06d9e)
Date Wed, 02 Sep 2020 22:18:20 GMT
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


Mime
View raw message