5,643 results
« Page 48 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java scanned file 6.1 KB StreamThreadStateStoreProvider.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java scanned file 13.4 KB ThreadCache.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java scanned file 32.5 KB TimeOrderedCachingWindowStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java scanned file 6.7 KB TimeOrderedKeyValueBufferChangelogDeserializationHelper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBuffer.java scanned file 3.2 KB TimeOrderedKeyValueBuffer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideDeserializer.java scanned file 3.3 KB TimestampedKeyAndJoinSideDeserializer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSide.java scanned file 3.8 KB TimestampedKeyAndJoinSide.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideSerde.java scanned file 1.4 KB TimestampedKeyAndJoinSideSerde.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideSerializer.java scanned file 2.8 KB TimestampedKeyAndJoinSideSerializer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java scanned file 6.7 KB TimestampedKeyValueStoreBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java scanned file 2.6 KB TimestampedSegment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java scanned file 3.0 KB TimestampedSegments.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java scanned file 8.7 KB TimestampedWindowStoreBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java scanned file 3.7 KB ValueAndTimestampDeserializer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java scanned file 1.5 KB ValueAndTimestampSerde.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java scanned file 5.3 KB ValueAndTimestampSerializer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueStoreBuilder.java scanned file 3.2 KB VersionedKeyValueStoreBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueToBytesStoreAdapter.java scanned file 6.9 KB VersionedKeyValueToBytesStoreAdapter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java scanned file 10.2 KB WindowKeySchema.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java scanned file 3.4 KB WindowStoreBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java scanned file 4.9 KB WindowStoreIteratorWrapper.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java scanned file 8.8 KB WindowToTimestampedWindowByteStoreAdapter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java scanned file 2.2 KB WrappedSessionStoreIterator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java scanned file 4.6 KB WrappedStateStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java scanned file 3.1 KB WrappingStoreProvider.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java scanned file 1.5 KB KeyValueBytesStoreSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java scanned file 1.6 KB KeyValueIterator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java scanned file 3.0 KB KeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/package-info.java scanned file 940 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java scanned file 2.0 KB QueryableStoreType.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java scanned file 7.1 KB QueryableStoreTypes.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java scanned file 7.0 KB ReadOnlyKeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java scanned file 21.7 KB ReadOnlySessionStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java scanned file 10.8 KB ReadOnlyWindowStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java scanned file 2.8 KB RocksDBConfigSetter.java .java Java text/html apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java scanned file 1.9 KB SessionBytesStoreSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java scanned file 6.5 KB SessionStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java scanned file 7.3 KB StateSerdes.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java scanned file 2.8 KB StoreBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/Stores.java scanned file 33.1 KB Stores.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java scanned file 1.6 KB StoreSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/TimestampedBytesStore.java scanned file 1.3 KB TimestampedBytesStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/TimestampedKeyValueStore.java scanned file 1.1 KB TimestampedKeyValueStore.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/TimestampedWindowStore.java scanned file 1.5 KB TimestampedWindowStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/ValueAndTimestamp.java scanned file 3.5 KB ValueAndTimestamp.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/VersionedBytesStore.java scanned file 1.5 KB VersionedBytesStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/VersionedBytesStoreSupplier.java scanned file 2.3 KB VersionedBytesStoreSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/VersionedKeyValueStore.java scanned file 7.8 KB VersionedKeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/VersionedRecordIterator.java scanned file 1.3 KB VersionedRecordIterator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/VersionedRecord.java scanned file 2.9 KB VersionedRecord.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java scanned file 2.4 KB WindowBytesStoreSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java scanned file 1.4 KB WindowStoreIterator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java scanned file 9.4 KB WindowStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/StoreQueryParameters.java scanned file 4.8 KB StoreQueryParameters.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java scanned file 33.3 KB StreamsBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java scanned file 111.9 KB StreamsConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/StreamsMetadata.java scanned file 3.4 KB StreamsMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java scanned file 7.2 KB StreamsMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/TaskMetadata.java scanned file 2.7 KB TaskMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/ThreadMetadata.java scanned file 3.4 KB ThreadMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java scanned file 19.6 KB TopologyConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java scanned file 6.7 KB TopologyDescription.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/Topology.java scanned file 48.6 KB Topology.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/common/metrics/SensorAccessor.java scanned file 1.2 KB SensorAccessor.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/AutoOffsetResetTest.java scanned file 4.3 KB AutoOffsetResetTest.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/EqualityCheck.java scanned file 5.4 KB EqualityCheck.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/errors/ExceptionHandlerUtilsTest.java scanned file 6.3 KB ExceptionHandlerUtilsTest.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/internals/ApiUtilsTest.java scanned file 4.6 KB ApiUtilsTest.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/internals/metrics/ClientMetricsTest.java scanned file 8.4 KB ClientMetricsTest.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/internals/metrics/StreamsClientMetricsDelegatingReporterTest.java scanned file 4.9 KB StreamsClientMetricsDelegatingReporterTest.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/internals/metrics/StreamsThreadMetricsDelegatingReporterTest.java scanned file 5.9 KB StreamsThreadMetricsDelegatingReporterTest.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/KafkaStreamsTest.java scanned file 89.4 KB KafkaStreamsTest.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/KeyValueTest.java scanned file 3.6 KB KeyValueTest.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/KeyValueTimestamp.java scanned file 1.9 KB KeyValueTimestamp.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/kstream/internals/AbstractStreamTest.java scanned file 5.2 KB AbstractStreamTest.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/kstream/internals/ChangedSerdeTest.java scanned file 8.3 KB ChangedSerdeTest.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/kstream/internals/CogroupedKStreamImplTest.java scanned file 75.5 KB CogroupedKStreamImplTest.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/kstream/internals/foreignkeyjoin/CombinedKeySchemaTest.java scanned file 3.5 KB CombinedKeySchemaTest.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/kstream/internals/foreignkeyjoin/ForeignTableJoinProcessorSupplierTests.java scanned file 7.9 KB ForeignTableJoinProcessorSupplierTests.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/kstream/internals/foreignkeyjoin/ResponseJoinProcessorSupplierTest.java scanned file 12.7 KB ResponseJoinProcessorSupplierTest.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/kstream/internals/foreignkeyjoin/SubscriptionJoinProcessorSupplierTest.java scanned file 14.6 KB SubscriptionJoinProcessorSupplierTest.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/kstream/internals/foreignkeyjoin/SubscriptionReceiveProcessorSupplierTest.java scanned file 21.5 KB SubscriptionReceiveProcessorSupplierTest.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/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerdeTest.java scanned file 7.1 KB SubscriptionResponseWrapperSerdeTest.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/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplierTest.java scanned file 30.7 KB SubscriptionSendProcessorSupplierTest.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/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerdeTest.java scanned file 12.4 KB SubscriptionWrapperSerdeTest.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/kstream/internals/FullChangeSerdeTest.java scanned file 4.7 KB FullChangeSerdeTest.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/kstream/internals/GlobalKTableJoinsTest.java scanned file 4.6 KB GlobalKTableJoinsTest.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/kstream/internals/graph/GraphGraceSearchUtilTest.java scanned file 10.4 KB GraphGraceSearchUtilTest.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/kstream/internals/graph/GraphNodeTest.java scanned file 4.6 KB GraphNodeTest.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/kstream/internals/graph/StreamsGraphTest.java scanned file 39.2 KB StreamsGraphTest.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/kstream/internals/graph/TableSourceNodeTest.java scanned file 3.9 KB TableSourceNodeTest.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/kstream/internals/InternalStreamsBuilderTest.java scanned file 68.0 KB InternalStreamsBuilderTest.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/kstream/internals/KGroupedStreamImplTest.java scanned file 37.4 KB KGroupedStreamImplTest.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/kstream/internals/KGroupedTableImplTest.java scanned file 15.4 KB KGroupedTableImplTest.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/kstream/internals/KStreamFilterTest.java scanned file 4.0 KB KStreamFilterTest.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/kstream/internals/KStreamFlatMapTest.java scanned file 4.4 KB KStreamFlatMapTest.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/kstream/internals/KStreamFlatMapValuesTest.java scanned file 5.4 KB KStreamFlatMapValuesTest.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/kstream/internals/KStreamForeachTest.java scanned file 3.8 KB KStreamForeachTest.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/kstream/internals/KStreamGlobalKTableJoinTest.java scanned file 12.9 KB KStreamGlobalKTableJoinTest.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/kstream/internals/KStreamGlobalKTableLeftJoinTest.java scanned file 13.6 KB KStreamGlobalKTableLeftJoinTest.java .java Java text/x-java apache-2.0