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%)
