This is an automated email from the ASF dual-hosted git repository.
Amar3tto pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 8a7c972c61b Merge pull request #39558 from apache/fix-auditkeys
add 621a78cd412 Add Beam YAML support for DebeziumIO
add 01c668b1455 Add Debezium YAML integration test
add a2267554a16 Fix record schema
add 25ed2f8b5b7 With max num of records
add aae48ec3ff0 Add setters
add 2541fc77cb3 Refactoring
add 315ed95a97d Fix python formatter
add b85646bf8df Remove primaryKeyColumns options
add 5178343b652 Fix spotless
new 0de9a676681 Merge pull request #39457 from apache/debezium-io-yaml
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:
.../org/apache/beam/io/debezium/DebeziumIO.java | 16 +--
.../DebeziumReadSchemaTransformProvider.java | 96 +++++++++++---
.../DebeziumReadSchemaTransformProviderTest.java | 139 +++++++++++++++++++++
.../databases/debezium.yaml} | 41 +++---
sdks/python/apache_beam/yaml/integration_tests.py | 73 ++++++++++-
sdks/python/apache_beam/yaml/standard_io.yaml | 23 ++++
sdks/python/build.gradle | 4 +-
7 files changed, 339 insertions(+), 53 deletions(-)
create mode 100644
sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformProviderTest.java
copy sdks/python/apache_beam/yaml/{tests/map.yaml =>
extended_tests/databases/debezium.yaml} (55%)
