6,843 results
« Page 51 of 69 »
Detected license expression: apache-2.0
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java scanned file 58.3 KB TableTableJoinIntegrationTest.java .java Java text/x-Algol68 apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java scanned file 8.5 KB TaskAssignorIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TaskMetadataIntegrationTest.java scanned file 8.6 KB TaskMetadataIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TestingMetricsInterceptingAdminClient.java scanned file 24.8 KB TestingMetricsInterceptingAdminClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TestTaskAssignor.java scanned file 1.9 KB TestTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TimeWindowedKStreamIntegrationTest.java scanned file 23.7 KB TimeWindowedKStreamIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/CompositeStateListener.java scanned file 1.9 KB CompositeStateListener.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java scanned file 23.9 KB EmbeddedKafkaCluster.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java scanned file 67.8 KB IntegrationTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java scanned file 36.5 KB VersionedKeyValueStoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/resources/log4j2.yaml scanned file 1.8 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala scanned file 7.5 KB StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinScalaIntegrationTestBase.scala scanned file 5.1 KB StreamToTableJoinScalaIntegrationTestBase.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinTestData.scala scanned file 2.2 KB StreamToTableJoinTestData.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/WordCountTest.scala scanned file 9.1 KB WordCountTest.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java scanned file 2.9 KB LineSplit.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java scanned file 2.6 KB Pipe.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java scanned file 3.5 KB WordCount.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/resources/log4j2.yaml scanned file 1.1 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/META-INF/maven/archetype-metadata.xml scanned file 1.5 KB archetype-metadata.xml .xml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test/resources/projects/basic/archetype.properties scanned file 886 bytes archetype.properties .properties text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/AutoOffsetReset.java scanned file 3.8 KB AutoOffsetReset.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/ClientInstanceIds.java scanned file 1.8 KB ClientInstanceIds.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/CloseOptions.java scanned file 3.9 KB CloseOptions.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/errors/BrokerNotFoundException.java scanned file 1.5 KB BrokerNotFoundException.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/errors/DefaultProductionExceptionHandler.java scanned file 2.7 KB DefaultProductionExceptionHandler.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/errors/DeserializationExceptionHandler.java scanned file 9.6 KB DeserializationExceptionHandler.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/errors/ErrorHandlerContext.java scanned file 8.6 KB ErrorHandlerContext.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/errors/internals/DefaultErrorHandlerContext.java scanned file 3.8 KB DefaultErrorHandlerContext.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/errors/internals/ExceptionHandlerUtils.java scanned file 5.8 KB ExceptionHandlerUtils.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/errors/internals/FailedProcessingException.java scanned file 1.9 KB FailedProcessingException.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/errors/InternalTopicsAlreadySetupException.java scanned file 1.0 KB InternalTopicsAlreadySetupException.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/errors/InvalidStateStoreException.java scanned file 1.5 KB InvalidStateStoreException.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/errors/InvalidStateStorePartitionException.java scanned file 1.6 KB InvalidStateStorePartitionException.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/errors/LockException.java scanned file 1.4 KB LockException.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/errors/LogAndContinueExceptionHandler.java scanned file 2.4 KB LogAndContinueExceptionHandler.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/errors/LogAndContinueProcessingExceptionHandler.java scanned file 2.5 KB LogAndContinueProcessingExceptionHandler.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/errors/LogAndFailExceptionHandler.java scanned file 2.4 KB LogAndFailExceptionHandler.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/errors/LogAndFailProcessingExceptionHandler.java scanned file 2.5 KB LogAndFailProcessingExceptionHandler.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/errors/MisconfiguredInternalTopicException.java scanned file 1.0 KB MisconfiguredInternalTopicException.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/errors/MissingInternalTopicsException.java scanned file 1.5 KB MissingInternalTopicsException.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/errors/MissingSourceTopicException.java scanned file 1.0 KB MissingSourceTopicException.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/errors/package-info.java scanned file 910 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/errors/ProcessingExceptionHandler.java scanned file 8.1 KB ProcessingExceptionHandler.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/errors/ProcessorStateException.java scanned file 1.4 KB ProcessorStateException.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/errors/ProductionExceptionHandler.java scanned file 15.3 KB ProductionExceptionHandler.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/errors/StateStoreMigratedException.java scanned file 1.6 KB StateStoreMigratedException.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/errors/StateStoreNotAvailableException.java scanned file 1.6 KB StateStoreNotAvailableException.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/errors/StreamsException.java scanned file 2.8 KB StreamsException.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/errors/StreamsNotStartedException.java scanned file 1.6 KB StreamsNotStartedException.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/errors/StreamsRebalancingException.java scanned file 1.6 KB StreamsRebalancingException.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/errors/StreamsStoppedException.java scanned file 1.6 KB StreamsStoppedException.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/errors/StreamsUncaughtExceptionHandler.java scanned file 2.1 KB StreamsUncaughtExceptionHandler.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/errors/TaskAssignmentException.java scanned file 1.5 KB TaskAssignmentException.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/errors/TaskCorruptedException.java scanned file 2.1 KB TaskCorruptedException.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/errors/TaskIdFormatException.java scanned file 1.6 KB TaskIdFormatException.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/errors/TaskMigratedException.java scanned file 1.6 KB TaskMigratedException.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/errors/TopologyException.java scanned file 1.6 KB TopologyException.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/errors/UnknownStateStoreException.java scanned file 1.4 KB UnknownStateStoreException.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/errors/UnknownTopologyException.java scanned file 1.5 KB UnknownTopologyException.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/GroupProtocol.java scanned file 1.4 KB GroupProtocol.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/internals/ApiUtils.java scanned file 3.8 KB ApiUtils.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/internals/AutoOffsetResetInternal.java scanned file 1.7 KB AutoOffsetResetInternal.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/internals/ClientInstanceIdsImpl.java scanned file 2.2 KB ClientInstanceIdsImpl.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/internals/CloseOptionsInternal.java scanned file 1.2 KB CloseOptionsInternal.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/internals/ConsumerWrapper.java scanned file 9.5 KB ConsumerWrapper.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/internals/metrics/ClientMetrics.java scanned file 7.9 KB ClientMetrics.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/internals/metrics/StreamsClientMetricsDelegatingReporter.java scanned file 2.7 KB StreamsClientMetricsDelegatingReporter.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/internals/metrics/StreamsThreadMetricsDelegatingReporter.java scanned file 3.7 KB StreamsThreadMetricsDelegatingReporter.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/internals/StreamsConfigUtils.java scanned file 3.6 KB StreamsConfigUtils.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/internals/UpgradeFromValues.java scanned file 1.7 KB UpgradeFromValues.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/KafkaClientSupplier.java scanned file 3.5 KB KafkaClientSupplier.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/KafkaStreams.java scanned file 102.1 KB KafkaStreams.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/KeyQueryMetadata.java scanned file 3.5 KB KeyQueryMetadata.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/KeyValue.java scanned file 2.3 KB KeyValue.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/kstream/Aggregator.java scanned file 2.3 KB Aggregator.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/kstream/Branched.java scanned file 6.8 KB Branched.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/kstream/BranchedKStream.java scanned file 9.5 KB BranchedKStream.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/kstream/CogroupedKStream.java scanned file 20.5 KB CogroupedKStream.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/kstream/Consumed.java scanned file 13.3 KB Consumed.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/kstream/EmitStrategy.java scanned file 3.8 KB EmitStrategy.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/kstream/ForeachAction.java scanned file 1.6 KB ForeachAction.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/kstream/ForeachProcessor.java scanned file 1.4 KB ForeachProcessor.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/kstream/GlobalKTable.java scanned file 4.3 KB GlobalKTable.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/kstream/Grouped.java scanned file 7.6 KB Grouped.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/kstream/Initializer.java scanned file 1.7 KB Initializer.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/kstream/internals/AbstractConfigurableStoreFactory.java scanned file 2.1 KB AbstractConfigurableStoreFactory.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/kstream/internals/AbstractKStreamTimeWindowAggregateProcessor.java scanned file 10.7 KB AbstractKStreamTimeWindowAggregateProcessor.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/kstream/internals/AbstractStream.java scanned file 5.1 KB AbstractStream.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/kstream/internals/BranchedInternal.java scanned file 1.6 KB BranchedInternal.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/kstream/internals/BranchedKStreamImpl.java scanned file 5.2 KB BranchedKStreamImpl.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/kstream/internals/ChangedDeserializer.java scanned file 5.8 KB ChangedDeserializer.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/kstream/internals/ChangedSerializer.java scanned file 5.5 KB ChangedSerializer.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/kstream/internals/Change.java scanned file 1.9 KB Change.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/kstream/internals/CogroupedKStreamImpl.java scanned file 6.5 KB CogroupedKStreamImpl.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/kstream/internals/CogroupedStreamAggregateBuilder.java scanned file 15.4 KB CogroupedStreamAggregateBuilder.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/kstream/internals/ConsumedInternal.java scanned file 1.9 KB ConsumedInternal.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/kstream/internals/emitstrategy/WindowCloseStrategy.java scanned file 1.1 KB WindowCloseStrategy.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/kstream/internals/emitstrategy/WindowUpdateStrategy.java scanned file 1.1 KB WindowUpdateStrategy.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/kstream/internals/ForeachProcessor.java scanned file 1.4 KB ForeachProcessor.java .java Java text/x-java apache-2.0