Code

DebeziumIO schema transform#24629

Code

Merged

pabloem merged 11 commits intoapache:masterapache/beam:masterfrom pabloem:debeziumio-stpabloem/beam:debeziumio-stCopy head branch name to clipboardDec 20, 2022

+882-62

Commits

Commits on Dec 9, 2022

• prototyping a debezium-based schema transform for continuous ingestion of change streams from databases

  pabloem

  committed
  ecd8c76

Commits on Dec 12, 2022

• Writing a significant integration test for DebeziumIO SchemaTransformProvider

  pabloem

  committed
  3a1f400

• Improvements to debuggability, performance on expansion

  pabloem

  committed
  efb1dcc

• fix tests. mysql integration test remaining

  pabloem

  committed
  e7f8375

• fixing and improving mysql test

  pabloem

  committed
  0ae60ea

Commits on Dec 13, 2022

• Fix JdbcIO issue

  pabloem

  committed
  30fd6f2

• add integration tests and reduce size for now

  pabloem

  committed
  0385c25

• fixup

  pabloem

  committed
  03168e2

• passing tests

  pabloem

  committed
  d5c9751

Commits on Dec 20, 2022

• Address comments

  pabloem

  committed
  1383126

• add comment

  pabloem

  committed
  59dbd09