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 2022/08/26 20:36:27 UTC

[beam] branch master updated (0c82583d6ac -> e9089dd9963)

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 0c82583d6ac Add map state in the Go Sdk (#22897)
     add e9089dd9963 [BEAM-12164] Feat: Added support to Cloud Spanner Change Streams connector for including transaction tags in the Change Stream records (#22769)

No new revisions were added by this update.

Summary of changes:
 .../mapper/ChangeStreamRecordMapper.java           |  4 +++
 .../changestreams/model/DataChangeRecord.java      | 33 +++++++++++++++++++++-
 .../dofn/PostProcessingMetricsDoFnTest.java        |  2 ++
 ...nnerChangeStreamOrderedWithinKeyGloballyIT.java |  2 ++
 .../it/SpannerChangeStreamOrderedWithinKeyIT.java  |  2 ++
 .../mapper/ChangeStreamRecordMapperTest.java       |  8 ++++++
 .../changestreams/model/DataChangeRecordTest.java  |  4 +++
 .../changestreams/model/ModelEncodingTest.java     |  4 +++
 .../changestreams/util/TestStructMapper.java       | 12 ++++++--
 9 files changed, 68 insertions(+), 3 deletions(-)