This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 6c083df5f8e SQL Database DDL & Usability Improvements (#38952)
add 001093e5e0b [mqtt] Add portable MqttIO Read/Write transforms for batch
and streaming (revives #32385) (#38493)
add b3a62ee97c7 Upgrade expansion jar to java17 (#38931)
No new revisions were added by this update.
Summary of changes:
.../actions/setup-environment-action/action.yml | 2 +-
.../beam_PreCommit_Xlang_Generated_Transforms.yml | 2 +-
sdks/java/expansion-service/container/Dockerfile | 2 +-
sdks/java/io/expansion-service/build.gradle | 5 +-
.../messaging-expansion-service}/build.gradle | 23 +-
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 7 +
.../io/mqtt/MqttReadSchemaTransformProvider.java | 150 ++++++++++++
.../io/mqtt/MqttWriteSchemaTransformProvider.java | 132 +++++++++++
.../io/mqtt/MqttSchemaTransformProviderTest.java | 252 +++++++++++++++++++++
sdks/python/build.gradle | 1 +
sdks/python/test-suites/xlang/build.gradle | 3 +-
sdks/standard_expansion_services.yaml | 15 ++
sdks/standard_external_transforms.yaml | 57 ++++-
settings.gradle.kts | 1 +
14 files changed, 637 insertions(+), 15 deletions(-)
copy sdks/java/{expansion-service/app =>
io/messaging-expansion-service}/build.gradle (69%)
create mode 100644
sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttReadSchemaTransformProvider.java
create mode 100644
sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttWriteSchemaTransformProvider.java
create mode 100644
sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttSchemaTransformProviderTest.java
