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/02/07 19:20:33 UTC

[beam] branch master updated (64581e0 -> d3b680e)

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 64581e0  [BEAM-13767] Migrate a bundle of grade tasks to use configuration avoidance API. (#16648)
     add d3b680e  Merge pull request #16653 from [BEAM-12164]: Add integration tests for spanner change streams

No new revisions were added by this update.

Summary of changes:
 .../action/ChildPartitionsRecordAction.java        |   1 -
 .../action/QueryChangeStreamAction.java            |   2 -
 .../spanner/changestreams/dofn/InitializeDoFn.java |   7 +-
 .../it/ChangeStreamTestPipelineOptions.java}       |  25 +-
 .../changestreams/it/IntegrationTestEnv.java       | 203 +++++++++++
 .../changestreams/it/SpannerChangeStreamIT.java    | 212 +++++++++++
 .../it/SpannerChangeStreamOrderedWithinKeyIT.java  | 393 +++++++++++++++++++++
 7 files changed, 827 insertions(+), 16 deletions(-)
 copy sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/{bigtable/BigtableTestOptions.java => spanner/changestreams/it/ChangeStreamTestPipelineOptions.java} (59%)
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/IntegrationTestEnv.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamIT.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/it/SpannerChangeStreamOrderedWithinKeyIT.java