5,643 results
« Page 50 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.java scanned file 9.5 KB GlobalProcessorContextImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java scanned file 49.1 KB GlobalStateManagerImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java scanned file 13.7 KB GlobalStateTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStreamThreadTest.java scanned file 18.1 KB GlobalStreamThreadTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/HighAvailabilityStreamsPartitionAssignorTest.java scanned file 15.5 KB HighAvailabilityStreamsPartitionAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicConfigTest.java scanned file 6.5 KB InternalTopicConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java scanned file 99.3 KB InternalTopicManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java scanned file 69.8 KB InternalTopologyBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/KeyValueStoreMaterializerTest.java scanned file 14.1 KB KeyValueStoreMaterializerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest.java scanned file 7.0 KB ProcessorNodeMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/RebalanceListenerMetricsTest.java scanned file 5.2 KB RebalanceListenerMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.java scanned file 62.4 KB StreamsMetricsImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetricsTest.java scanned file 11.9 KB TaskMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetricsTest.java scanned file 20.5 KB ThreadMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/TopicMetricsTest.java scanned file 5.1 KB TopicMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/MockChangelogReader.java scanned file 2.9 KB MockChangelogReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/MockStreamsMetrics.java scanned file 1.2 KB MockStreamsMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java scanned file 15.8 KB NamedTopologyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGrouperTest.java scanned file 5.1 KB PartitionGrouperTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/PartitionGroupTest.java scanned file 42.1 KB PartitionGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java scanned file 37.2 KB ProcessorContextImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java scanned file 3.3 KB ProcessorContextTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorMetadataTest.java scanned file 5.6 KB ProcessorMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java scanned file 25.8 KB ProcessorNodeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContextTest.java scanned file 3.3 KB ProcessorRecordContextTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java scanned file 52.1 KB ProcessorStateManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyFactories.java scanned file 2.5 KB ProcessorTopologyFactories.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java scanned file 67.1 KB ProcessorTopologyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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