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
