This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from bb310e0b87a Document compact lifecycle method (#29466)
add 67dbdd196ab Upgrade Kafka read/write transforms without upgrading the
pipeline (#29362)
No new revisions were added by this update.
Summary of changes:
.../core/construction/TransformUpgrader.java | 49 +-
sdks/java/io/expansion-service/build.gradle | 2 +
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 85 +--
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 4 +-
.../python => io/kafka/upgrade}/build.gradle | 36 +-
.../sdk/io/kafka/upgrade/KafkaIOTranslation.java | 578 +++++++++++++++++++++
.../beam/sdk/io/kafka/upgrade}/package-info.java | 4 +-
.../io/kafka/upgrade/KafkaIOTranslationTest.java | 256 +++++++++
settings.gradle.kts | 1 +
9 files changed, 958 insertions(+), 57 deletions(-)
copy sdks/java/{extensions/python => io/kafka/upgrade}/build.gradle (60%)
create mode 100644
sdks/java/io/kafka/upgrade/src/main/java/org/apache/beam/sdk/io/kafka/upgrade/KafkaIOTranslation.java
copy
{.test-infra/pipelines/src/main/java/org/apache/beam/testinfra/pipelines/bigquery
=>
sdks/java/io/kafka/upgrade/src/main/java/org/apache/beam/sdk/io/kafka/upgrade}/package-info.java
(85%)
create mode 100644
sdks/java/io/kafka/upgrade/src/test/java/org/apache/beam/sdk/io/kafka/upgrade/KafkaIOTranslationTest.java
