[beam] branch master updated (4fa5c43fa89 -> 99f2a75a69e)

[pa...@apache.org]

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 4fa5c43fa89 [BEAM-14527] Implement "Beam Summit 2022" banner (#17776)
     add 99f2a75a69e Merge pull request #17222 from [BEAM-12164] Feat: Add new restriction tracker to be able to track partition state along with timestamp for change streams connector.

No new revisions were added by this update.

Summary of changes:
 .../{package-info.java => PartitionMode.java}      |  20 +-
 .../restriction/PartitionPosition.java             |  90 +++
 .../restriction/PartitionRestriction.java          | 141 ++++
 .../restriction/PartitionRestrictionClaimer.java   | 136 ++++
 .../restriction/PartitionRestrictionMetadata.java  | 106 +++
 .../PartitionRestrictionProgressChecker.java       |  96 +++
 .../restriction/PartitionRestrictionSplitter.java  | 128 +++
 .../restriction/PartitionRestrictionTracker.java   | 159 ++++
 .../restriction/PartitionPositionTest.java         |  70 ++
 .../PartitionRestrictionClaimerTest.java           | 272 +++++++
 .../PartitionRestrictionProgressCheckerTest.java   | 230 ++++++
 .../PartitionRestrictionSplitterTest.java          | 168 ++++
 .../restriction/PartitionRestrictionTest.java      |  78 ++
 .../PartitionRestrictionTrackerTest.java           | 859 +++++++++++++++++++++
 ...erator.java => PartitionPositionGenerator.java} |  26 +-
 15 files changed, 2568 insertions(+), 11 deletions(-)
 copy sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/{package-info.java => PartitionMode.java} (56%)
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionPosition.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestriction.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionClaimer.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionMetadata.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionProgressChecker.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionSplitter.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionTracker.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionPositionTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionClaimerTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionProgressCheckerTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionSplitterTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/restriction/PartitionRestrictionTrackerTest.java
 copy sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/util/{TimestampGenerator.java => PartitionPositionGenerator.java} (56%)