This is an automated email from the ASF dual-hosted git repository.
je-ik pushed a change to branch feat/18479-kafka-streams-runner-skeleton
in repository https://gitbox.apache.org/repos/asf/beam.git
from 10ff557d616 [GSoC 2026] Kafka Streams runner: an application for
measuring instances coming and going (#39752)
add 5b3702484f4 [GSoC 2026] Kafka Streams runner: license header and
Python formatting for master CI
add b12bfc159ba [GSoC 2026] Kafka Streams runner: shorten the explanation
comments
new 8d5f6511a6b Merge pull request #39781: [GSoC 2026] Kafka Streams
runner: shorten comments, and fix the license header and Python formatting
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
