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

Posted to commits@beam.apache.org by sc...@apache.org on 2025/01/07 08:39:21 UTC

(beam) branch master updated (e657d6c8cec -> 43b2bf7cb20)

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

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


    from e657d6c8cec Adds an SdkHarnessOption that controls whether logging is redirected through the FnApi (#33418)
     add 43b2bf7cb20 [feat 32473] Added soft deadline logic to Spanner Change Stream IO connector. (#32474)

No new revisions were added by this update.

Summary of changes:
 .../action/ChildPartitionsRecordAction.java        |  14 ++-
 .../action/DataChangeRecordAction.java             |  15 ++-
 .../action/HeartbeatRecordAction.java              |  11 +-
 .../action/QueryChangeStreamAction.java            |  25 +++-
 .../restriction/RestrictionInterrupter.java        |  85 ++++++++++++++
 .../action/ChildPartitionsRecordActionTest.java    |  38 +++++-
 .../action/DataChangeRecordActionTest.java         |  26 ++++-
 .../action/HeartbeatRecordActionTest.java          |  38 +++++-
 .../action/QueryChangeStreamActionTest.java        | 130 ++++++++++++++++-----
 .../dofn/ReadChangeStreamPartitionDoFnTest.java    |   6 +-
 .../restriction/RestrictionInterrupterTest.java    |  65 +++++++++++
 11 files changed, 409 insertions(+), 44 deletions(-)
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/RestrictionInterrupter.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/RestrictionInterrupterTest.java