6,866 results
« Page 60 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/PunctuationQueueTest.java scanned file 7.4 KB PunctuationQueueTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/QuickUnionTest.java scanned file 2.9 KB QuickUnionTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RackAwarenessStreamsPartitionAssignorTest.java scanned file 29.4 KB RackAwarenessStreamsPartitionAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ReadOnlyTaskTest.java scanned file 7.6 KB ReadOnlyTaskTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java scanned file 100.3 KB RecordCollectorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordDeserializerTest.java scanned file 19.6 KB RecordDeserializerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordQueueTest.java scanned file 23.1 KB RecordQueueTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionOptimizingTest.java scanned file 27.6 KB RepartitionOptimizingTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfigTest.java scanned file 2.6 KB RepartitionTopicConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicsTest.java scanned file 22.8 KB RepartitionTopicsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionWithMergeOptimizingTest.java scanned file 18.7 KB RepartitionWithMergeOptimizingTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/SinkNodeTest.java scanned file 5.2 KB SinkNodeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/SourceNodeTest.java scanned file 8.4 KB SourceNodeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java scanned file 22.7 KB StandbyTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateConsumerTest.java scanned file 5.5 KB StateConsumerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java scanned file 35.9 KB StateDirectoryTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerStub.java scanned file 2.2 KB StateManagerStub.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java scanned file 10.5 KB StateManagerUtilTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapterTest.java scanned file 5.7 KB StateRestoreCallbackAdapterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java scanned file 69.7 KB StoreChangelogReaderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsAssignmentScaleTest.java scanned file 14.0 KB StreamsAssignmentScaleTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsMetadataStateTest.java scanned file 19.3 KB StreamsMetadataStateTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java scanned file 142.9 KB StreamsPartitionAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java scanned file 36.3 KB StreamsProducerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListenerTest.java scanned file 6.5 KB StreamsRebalanceListenerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java scanned file 146.1 KB StreamTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java scanned file 202.3 KB StreamThreadTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTotalBlockedTimeTest.java scanned file 4.2 KB StreamThreadTotalBlockedTimeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/SynchronizedPartitionGroupTest.java scanned file 6.9 KB SynchronizedPartitionGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskAndActionTest.java scanned file 3.8 KB TaskAndActionTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadataTest.java scanned file 5.3 KB TaskExecutionMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutorTest.java scanned file 2.6 KB TaskExecutorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java scanned file 243.9 KB TaskManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskMetadataImplTest.java scanned file 5.9 KB TaskMetadataImplTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutorTest.java scanned file 10.7 KB DefaultTaskExecutorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManagerTest.java scanned file 18.3 KB DefaultTaskManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TasksTest.java scanned file 12.6 KB TasksTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskSuite.java scanned file 1.7 KB TaskSuite.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/ConsumerRecordUtil.java scanned file 1.9 KB ConsumerRecordUtil.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/testutil/DummyStreamsConfig.java scanned file 1.7 KB DummyStreamsConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ThreadMetadataImplTest.java scanned file 8.9 KB ThreadMetadataImplTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TopicPartitionMetadataTest.java scanned file 4.1 KB TopicPartitionMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/TopologyMetadataTest.java scanned file 3.3 KB TopologyMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/WriteConsistencyVectorTest.java scanned file 6.0 KB WriteConsistencyVectorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestampTest.java scanned file 2.0 KB LogAndSkipOnInvalidTimestampTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/ReadOnlyStoreTest.java scanned file 5.6 KB ReadOnlyStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/TimestampExtractorTest.java scanned file 1.7 KB TimestampExtractorTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestampTest.java scanned file 2.2 KB UsePartitionTimeOnInvalidTimestampTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/WallclockTimestampExtractorTest.java scanned file 2.2 KB WallclockTimestampExtractorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/query/MultiVersionedKeyQueryTest.java scanned file 1.3 KB MultiVersionedKeyQueryTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/query/PositionBoundTest.java scanned file 3.4 KB PositionBoundTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/query/PositionTest.java scanned file 14.3 KB PositionTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/query/StateQueryResultTest.java scanned file 2.5 KB StateQueryResultTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/query/VersionedKeyQueryTest.java scanned file 1.7 KB VersionedKeyQueryTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/HostInfoTest.java scanned file 1.8 KB HostInfoTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractDualSchemaRocksDBSegmentedBytesStoreTest.java scanned file 75.9 KB AbstractDualSchemaRocksDBSegmentedBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractKeyValueStoreTest.java scanned file 25.1 KB AbstractKeyValueStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStoreTest.java scanned file 43.2 KB AbstractRocksDBSegmentedBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractRocksDBWindowStoreTest.java scanned file 33.2 KB AbstractRocksDBWindowStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractSessionBytesStoreTest.java scanned file 46.2 KB AbstractSessionBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractWindowBytesStoreTest.java scanned file 50.4 KB AbstractWindowBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCacheTest.java scanned file 2.1 KB BlockBasedTableConfigWithAccessibleCacheTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/BufferValueTest.java scanned file 10.2 KB BufferValueTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CacheFlushListenerStub.java scanned file 1.9 KB CacheFlushListenerStub.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingInMemoryKeyValueStoreTest.java scanned file 24.1 KB CachingInMemoryKeyValueStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingInMemorySessionStoreTest.java scanned file 40.2 KB CachingInMemorySessionStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentSessionStoreTest.java scanned file 40.6 KB CachingPersistentSessionStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingPersistentWindowStoreTest.java scanned file 52.1 KB CachingPersistentWindowStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java scanned file 11.1 KB ChangeLoggingKeyValueBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStoreTest.java scanned file 7.0 KB ChangeLoggingSessionBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStoreTest.java scanned file 8.4 KB ChangeLoggingTimestampedKeyValueBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStoreTest.java scanned file 5.5 KB ChangeLoggingTimestampedWindowBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingVersionedKeyValueBytesStoreTest.java scanned file 8.9 KB ChangeLoggingVersionedKeyValueBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStoreTest.java scanned file 6.0 KB ChangeLoggingWindowBytesStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStoreTest.java scanned file 20.1 KB CompositeReadOnlyKeyValueStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStoreTest.java scanned file 9.8 KB CompositeReadOnlySessionStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStoreTest.java scanned file 25.2 KB CompositeReadOnlyWindowStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ContextualRecordTest.java scanned file 3.4 KB ContextualRecordTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIteratorTest.java scanned file 3.8 KB DelegatingPeekingKeyValueIteratorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/FilteredCacheIteratorTest.java scanned file 4.8 KB FilteredCacheIteratorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProviderTest.java scanned file 10.5 KB GlobalStateStoreProviderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueLoggedStoreTest.java scanned file 1.8 KB InMemoryKeyValueLoggedStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStoreTest.java scanned file 18.2 KB InMemoryKeyValueStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryLRUCacheStoreTest.java scanned file 5.9 KB InMemoryLRUCacheStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/InMemorySessionStoreTest.java scanned file 2.3 KB InMemorySessionStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBufferTest.java scanned file 2.6 KB InMemoryTimeOrderedKeyValueChangeBufferTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryWindowStoreTest.java scanned file 8.3 KB InMemoryWindowStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueIteratorFacadeTest.java scanned file 2.9 KB KeyValueIteratorFacadeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentsTest.java scanned file 15.0 KB KeyValueSegmentsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueSegmentTest.java scanned file 5.7 KB KeyValueSegmentTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilderTest.java scanned file 6.0 KB KeyValueStoreBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/KeyValueStoreWrapperTest.java scanned file 11.0 KB KeyValueStoreWrapperTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/LeftOrRightValueSerializerTest.java scanned file 3.0 KB LeftOrRightValueSerializerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/ListValueStoreTest.java scanned file 7.7 KB ListValueStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegmentsTest.java scanned file 10.6 KB LogicalKeyValueSegmentsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegmentTest.java scanned file 25.1 KB LogicalKeyValueSegmentTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/MaybeTest.java scanned file 3.1 KB MaybeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIteratorTest.java scanned file 12.0 KB MergedSortedCacheKeyValueBytesStoreIteratorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedSessionStoreIteratorTest.java scanned file 7.4 KB MergedSortedCacheWrappedSessionStoreIteratorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWrappedWindowStoreIteratorTest.java scanned file 13.0 KB MergedSortedCacheWrappedWindowStoreIteratorTest.java .java Java text/x-java apache-2.0