(kafka) branch trunk updated (6aa8f3c1196 -> 2d692e4506a)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from 6aa8f3c1196 KAFKA-16923 New Unit Test for stripDotPathComponents method (#16259)
     add 2d692e4506a KAFKA-15623 (3/N) Migrate test of Stream module to Junit5 (Stream state) (#16356)

No new revisions were added by this update.

Summary of changes:
 ...ctDualSchemaRocksDBSegmentedBytesStoreTest.java | 118 ++-
 .../state/internals/AbstractKeyValueStoreTest.java |  25 +-
 .../AbstractRocksDBSegmentedBytesStoreTest.java    | 160 +++--
 .../internals/AbstractRocksDBWindowStoreTest.java  | 790 +++++++++++++++++++++
 .../internals/AbstractSessionBytesStoreTest.java   | 102 ++-
 .../internals/AbstractWindowBytesStoreTest.java    |  29 +-
 ...ockBasedTableConfigWithAccessibleCacheTest.java |   2 +-
 .../streams/state/internals/BufferValueTest.java   |  10 +-
 .../CachingInMemoryKeyValueStoreTest.java          |  27 +-
 .../internals/CachingInMemorySessionStoreTest.java |  31 +-
 .../CachingPersistentSessionStoreTest.java         |  31 +-
 .../CachingPersistentWindowStoreTest.java          |  31 +-
 .../ChangeLoggingKeyValueBytesStoreTest.java       |  19 +-
 .../ChangeLoggingSessionBytesStoreTest.java        |  19 +-
 ...geLoggingTimestampedKeyValueBytesStoreTest.java |  19 +-
 ...angeLoggingTimestampedWindowBytesStoreTest.java |  19 +-
 ...angeLoggingVersionedKeyValueBytesStoreTest.java |  21 +-
 .../ChangeLoggingWindowBytesStoreTest.java         |  19 +-
 .../CompositeReadOnlyKeyValueStoreTest.java        |  16 +-
 .../CompositeReadOnlySessionStoreTest.java         |  14 +-
 .../CompositeReadOnlyWindowStoreTest.java          |  35 +-
 .../DelegatingPeekingKeyValueIteratorTest.java     |  13 +-
 .../state/internals/FilteredCacheIteratorTest.java |  12 +-
 .../internals/GlobalStateStoreProviderTest.java    |  21 +-
 .../state/internals/InMemoryKeyValueStoreTest.java |  14 +-
 .../state/internals/InMemoryLRUCacheStoreTest.java |   6 +-
 .../state/internals/InMemorySessionStoreTest.java  |  25 +-
 ...nMemoryTimeOrderedKeyValueChangeBufferTest.java |   2 +-
 .../state/internals/InMemoryWindowStoreTest.java   |   9 +-
 .../internals/KeyValueIteratorFacadeTest.java      |  19 +-
 .../state/internals/KeyValueSegmentTest.java       |  19 +-
 .../state/internals/KeyValueSegmentsTest.java      |  18 +-
 .../state/internals/KeyValueStoreBuilderTest.java  |  40 +-
 .../state/internals/KeyValueStoreWrapperTest.java  |  13 +-
 .../internals/LeftOrRightValueSerializerTest.java  |   4 +-
 .../state/internals/ListValueStoreTest.java        |  71 +-
 .../internals/LogicalKeyValueSegmentTest.java      |  20 +-
 .../internals/LogicalKeyValueSegmentsTest.java     |  18 +-
 .../kafka/streams/state/internals/MaybeTest.java   |   4 +-
 ...dSortedCacheKeyValueBytesStoreIteratorTest.java |  11 +-
 ...SortedCacheWrappedSessionStoreIteratorTest.java |   6 +-
 ...dSortedCacheWrappedWindowStoreIteratorTest.java |  66 +-
 ...acheWrappedWindowStoreKeyValueIteratorTest.java | 114 +--
 .../state/internals/MeteredKeyValueStoreTest.java  |  81 ++-
 .../state/internals/MeteredSessionStoreTest.java   |  86 ++-
 .../MeteredTimestampedKeyValueStoreTest.java       |  82 ++-
 .../MeteredTimestampedWindowStoreTest.java         |  51 +-
 .../MeteredVersionedKeyValueStoreTest.java         |  21 +-
 .../state/internals/MeteredWindowStoreTest.java    |  23 +-
 .../kafka/streams/state/internals/Murmur3Test.java |   7 +-
 .../streams/state/internals/NamedCacheTest.java    |  18 +-
 .../state/internals/OffsetCheckpointTest.java      |  10 +-
 .../internals/QueryableStoreProviderTest.java      |  10 +-
 .../internals/ReadOnlyKeyValueStoreFacadeTest.java |  17 +-
 .../internals/ReadOnlyWindowStoreFacadeTest.java   |  17 +-
 .../state/internals/RecordConvertersTest.java      |   6 +-
 ...sToDbOptionsColumnFamilyOptionsAdapterTest.java |  11 +-
 .../state/internals/RocksDBRangeIteratorTest.java  |  13 +-
 .../state/internals/RocksDBSessionStoreTest.java   |  72 +-
 .../streams/state/internals/RocksDBStoreTest.java  |  48 +-
 .../RocksDBTimeOrderedKeyValueBufferTest.java      |  15 +-
 ...ionSchemaWithIndexSegmentedBytesStoreTest.java} |  10 +-
 ...SchemaWithoutIndexSegmentedBytesStoreTest.java} |  10 +-
 ...cksDBTimeOrderedSessionStoreWithIndexTest.java} |  10 +-
 ...DBTimeOrderedSessionStoreWithoutIndexTest.java} |  10 +-
 ...dowSchemaWithIndexSegmentedBytesStoreTest.java} |  12 +-
 ...SchemaWithoutIndexSegmentedBytesStoreTest.java} |  10 +-
 ...DBTimeOrderedWindowSegmentedBytesStoreTest.java | 121 ----
 ...ocksDBTimeOrderedWindowStoreWithIndexTest.java} |  11 +-
 ...sDBTimeOrderedWindowStoreWithoutIndexTest.java} |  12 +-
 .../internals/RocksDBTimestampedStoreTest.java     |   6 +-
 ...sDBVersionedStoreSegmentValueFormatterTest.java | 472 ++++++------
 .../state/internals/RocksDBVersionedStoreTest.java |  12 +-
 .../state/internals/RocksDBWindowStoreTest.java    | 787 +-------------------
 ...xedTimeOrderedWindowBytesStoreSupplierTest.java |  10 +-
 ...sDbVersionedKeyValueBytesStoreSupplierTest.java |   2 +-
 .../state/internals/SegmentIteratorTest.java       |  18 +-
 .../internals/SegmentedCacheFunctionTest.java      |   2 +-
 .../state/internals/SessionKeySchemaTest.java      | 182 ++---
 .../state/internals/SessionStoreBuilderTest.java   |  34 +-
 .../state/internals/SessionStoreFetchTest.java     | 115 ++-
 .../state/internals/StoreQueryUtilsTest.java       |   2 +-
 .../StreamThreadStateStoreProviderTest.java        |  25 +-
 .../streams/state/internals/ThreadCacheTest.java   |  19 +-
 ...imeOrderedCachingPersistentWindowStoreTest.java | 340 +++++----
 .../internals/TimeOrderedKeyValueBufferTest.java   | 136 ++--
 .../internals/TimeOrderedWindowStoreTest.java      | 341 +++++----
 .../TimestampedKeyAndJoinSideSerializerTest.java   |   4 +-
 .../TimestampedKeyValueStoreBuilderTest.java       |  36 +-
 .../state/internals/TimestampedSegmentTest.java    |  19 +-
 .../state/internals/TimestampedSegmentsTest.java   |  18 +-
 .../TimestampedWindowStoreBuilderTest.java         | 129 ++--
 .../internals/ValueAndTimestampSerializerTest.java |   6 +-
 .../VersionedKeyValueStoreBuilderTest.java         |  34 +-
 .../state/internals/WindowKeySchemaTest.java       | 165 +++--
 .../state/internals/WindowStoreBuilderTest.java    |  40 +-
 .../state/internals/WindowStoreFetchTest.java      | 125 ++--
 .../state/internals/WrappingStoreProviderTest.java |  10 +-
 .../internals/metrics/NamedCacheMetricsTest.java   |   2 +-
 .../metrics/RocksDBMetricsRecorderGaugesTest.java  |   2 +-
 .../metrics/RocksDBMetricsRecorderTest.java        |   2 +-
 .../RocksDBMetricsRecordingTriggerTest.java        |  23 +-
 .../internals/metrics/RocksDBMetricsTest.java      |   3 +-
 .../internals/metrics/StateStoreMetricsTest.java   |   2 +-
 104 files changed, 3231 insertions(+), 2748 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBWindowStoreTest.java
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSchemaWithIndexSegmentedBytesStoreTest.java} (78%)
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSchemaWithoutIndexSegmentedBytesStoreTest.java} (77%)
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStoreWithIndexTest.java} (80%)
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStoreWithoutIndexTest.java} (79%)
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowSchemaWithIndexSegmentedBytesStoreTest.java} (78%)
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowSchemaWithoutIndexSegmentedBytesStoreTest.java} (78%)
 delete mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowSegmentedBytesStoreTest.java
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStoreWithIndexTest.java} (80%)
 copy streams/src/{main/java/org/apache/kafka/streams/state/internals/CacheFunction.java => test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStoreWithoutIndexTest.java} (79%)