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 f6ab250 [BEAM-13779] Fix pr labeling (#16665)
add 91738cb Merge pull request #16581 from [BEAM-12164]: Add
SpannerIO.readChangeStreams
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 317 +++++++++++++++++++--
.../gcp/spanner/changestreams/NameGenerator.java | 47 +++
.../changestreams/dao/PartitionMetadataDao.java | 21 ++
.../dofn/DetectNewPartitionsDoFn.java | 6 +-
.../spanner/changestreams/dofn/InitializeDoFn.java | 98 +++++++
.../dofn/PostProcessingMetricsDoFn.java | 115 ++++++++
.../dofn/ReadChangeStreamPartitionDoFn.java | 4 +-
.../mapper/ChangeStreamRecordMapper.java | 3 +
.../spanner/changestreams/NameGeneratorTest.java} | 30 +-
9 files changed, 597 insertions(+), 44 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/NameGenerator.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dofn/InitializeDoFn.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dofn/PostProcessingMetricsDoFn.java
copy
sdks/java/{core/src/test/java/org/apache/beam/sdk/util/ReleaseInfoTest.java =>
io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/NameGeneratorTest.java}
(56%)
