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 826e0fb Merge pull request #16095 from [BEAM-13360][Playground]
[Bugfix] Fix synchronous validators
add e856227 Merge pull request #16011 from [BEAM-12164] Add models for
Spanner change streams
No new revisions were added by this update.
Summary of changes:
.../changestreams/encoder/TimestampEncoding.java | 90 +++++
.../changestreams/encoder/package-info.java | 20 +
.../changestreams/model/ChangeStreamRecord.java | 36 ++
.../model/ChangeStreamRecordMetadata.java | 438 +++++++++++++++++++++
.../changestreams/model/ChildPartition.java | 118 ++++++
.../changestreams/model/ChildPartitionsRecord.java | 150 +++++++
.../spanner/changestreams/model/ColumnType.java | 107 +++++
.../changestreams/model/DataChangeRecord.java | 264 +++++++++++++
.../changestreams/model/HeartbeatRecord.java | 99 +++++
.../changestreams/model/InitialPartition.java | 48 +++
.../io/gcp/spanner/changestreams/model/Mod.java | 127 ++++++
.../gcp/spanner/changestreams/model/ModType.java | 33 ++
.../changestreams/model/PartitionMetadata.java | 403 +++++++++++++++++++
.../gcp/spanner/changestreams/model/TypeCode.java | 79 ++++
.../changestreams/model/ValueCaptureType.java | 31 ++
.../spanner/changestreams/model/package-info.java | 23 ++
.../io/gcp/spanner/changestreams/package-info.java | 27 ++
.../encoder/TimestampEncodingTest.java | 155 ++++++++
.../model/ChangeStreamRecordMetadataTest.java | 63 +++
.../model/ChildPartitionsRecordTest.java | 51 +++
.../changestreams/model/DataChangeRecordTest.java | 78 ++++
.../changestreams/model/HeartbeatRecordTest.java | 40 ++
.../changestreams/model/ModelEncodingTest.java | 177 +++++++++
.../changestreams/model/PartitionMetadataTest.java | 208 ++++++++++
24 files changed, 2865 insertions(+)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/encoder/TimestampEncoding.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/encoder/package-info.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChangeStreamRecord.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChangeStreamRecordMetadata.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChildPartition.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChildPartitionsRecord.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ColumnType.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/DataChangeRecord.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/HeartbeatRecord.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/InitialPartition.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/Mod.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ModType.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/PartitionMetadata.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/TypeCode.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ValueCaptureType.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/package-info.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/package-info.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/encoder/TimestampEncodingTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChangeStreamRecordMetadataTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChildPartitionsRecordTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/DataChangeRecordTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/HeartbeatRecordTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ModelEncodingTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/PartitionMetadataTest.java
