You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by pa...@apache.org on 2021/05/26 22:31:03 UTC

[beam] branch master updated (14f83bd -> ea4c0a1)

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 14f83bd  [BEAM-12024] Add DataFrame example pipeline README (#14886)
     add ea4c0a1  Merge pull request #14829 from [BEAM-11838] An x-lang wrapper for DebeziumIO

No new revisions were added by this update.

Summary of changes:
 .../expansion-service/build.gradle                 |  20 ++-
 .../org/apache/beam/io/debezium/Connectors.java    |  72 +++++++++
 .../io/debezium/DebeziumTransformRegistrar.java    | 125 +++++++++++++++
 .../beam/io/debezium/KafkaSourceConsumerFn.java    |  54 +++++--
 sdks/python/apache_beam/io/debezium.py             | 176 +++++++++++++++++++++
 .../io/external/xlang_debeziumio_it_test.py        | 123 ++++++++++++++
 sdks/python/test-suites/portable/common.gradle     |   2 +
 settings.gradle.kts                                |   1 +
 8 files changed, 551 insertions(+), 22 deletions(-)
 copy sdks/java/io/{google-cloud-platform => debezium}/expansion-service/build.gradle (57%)
 create mode 100644 sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/Connectors.java
 create mode 100644 sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumTransformRegistrar.java
 create mode 100644 sdks/python/apache_beam/io/debezium.py
 create mode 100644 sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py