This is an automated email from the ASF dual-hosted git repository. je-ik pushed a commit to branch feat/18479-kafka-streams-runner-skeleton in repository https://gitbox.apache.org/repos/asf/beam.git
commit 8d5f6511a6b183cb96f3e7f574ef2cbfd5e69237 Merge: 10ff557d616 b12bfc159ba Author: Jan Lukavský <[email protected]> AuthorDate: Mon Aug 17 11:13:26 2026 +0200 Merge pull request #39781: [GSoC 2026] Kafka Streams runner: shorten comments, and fix the license header and Python formatting .../kafka-streams/measurement/docker-compose.yml | 17 ++++ .../streams/measurement/RescalingMeasurement.java | 51 +++++------- .../kafka/streams/KafkaStreamsPipelineRunner.java | 35 +++----- .../translation/ExecutableStageProcessor.java | 93 +++++++++------------- .../streams/translation/FlattenProcessor.java | 28 +++---- .../streams/translation/GroupByKeyTranslator.java | 31 +++----- .../streams/translation/ImpulseProcessor.java | 29 +++---- .../streams/translation/ImpulseTranslator.java | 32 ++------ .../kafka/streams/translation/KStreamsPayload.java | 25 ++---- .../translation/KafkaStreamsTimerInternals.java | 31 +++----- .../KafkaStreamsTranslationContext.java | 61 ++++---------- .../kafka/streams/translation/ReadProcessor.java | 45 ++++------- .../kafka/streams/translation/ReadTranslator.java | 37 +++------ .../streams/translation/TerminationReporter.java | 28 +++---- .../streams/translation/TerminationTracker.java | 43 ++++------ .../translation/UnboundedReadProcessor.java | 63 ++++++--------- .../streams/translation/WatermarkAggregator.java | 31 +++----- .../streams/translation/WatermarkManager.java | 47 +++-------- .../runners/portability/kafka_streams_runner.py | 3 +- 19 files changed, 257 insertions(+), 473 deletions(-)
