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

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


The following commit(s) were added to refs/heads/master by this push:
     new 0202475bdad [DebeziumIO] Add CHANGES.md entry for opt-in full metadata 
(#40701) (#40743)
0202475bdad is described below

commit 0202475bdadc3b353d1bcca1b9b00c0326787c10
Author: Tobias Kaymak <[email protected]>
AuthorDate: Fri Oct 23 19:37:38 2026 +0200

    [DebeziumIO] Add CHANGES.md entry for opt-in full metadata (#40701) (#40743)
---
 CHANGES.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/CHANGES.md b/CHANGES.md
index 33e66880343..c9350da11d6 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -67,6 +67,7 @@
 * Support for X source added (Java/Python) 
([#X](https://github.com/apache/beam/issues/X)).
 * (Java) FirestoreIO: added 
`RpcQosOptions.Builder.withRampupThrottlingDisabled()`, mirroring the existing 
DatastoreIO option, to opt out of the 500/50/5 write ramp-up 
([#27170](https://github.com/apache/beam/issues/27170)).
 * Added support for attributing BigQuery API quota and billing to a specific 
GCP project (quota project): `quota_project_id` parameter in `ReadFromBigQuery` 
or `--quota_project_id` pipeline option, honored by the Python BigQuery IO 
transforms (`WriteToBigQuery` with `FILE_LOADS` or `STREAMING_INSERTS`; not yet 
`STORAGE_WRITE_API`, which is Java-backed), `--bigQueryQuotaProjectId` pipeline 
option (Java), and `bigqueryio.WithQuotaProject` read/query option (Go) 
([#37431](https://github.com [...]
+* (Java/Python/Go) DebeziumIO: `readAsJson()` can now include `op` and the 
remaining Debezium `source` fields (e.g. MySQL `file`, `pos`, `row`, `ts_ms`; 
PostgreSQL `lsn`, `txId`, `ts_ms`) in `metadata` via `withFullMetadata(true)` / 
`full_metadata=True` / `debeziumio.FullMetadata()`. Off by default 
([#40701](https://github.com/apache/beam/issues/40701)).
 
 ## New Features / Improvements
 

Reply via email to