This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f2d0dc8aecc Improve LogElements to show pane_info and timestamps in
seconds. (#35387)
add dc213a998c3 Add change stream new record models and tests. (#35258)
No new revisions were added by this update.
Summary of changes:
...rtitionsRecord.java => PartitionEndRecord.java} | 80 ++++++++--------------
...itionsRecord.java => PartitionEventRecord.java} | 79 ++++++++-------------
...itionsRecord.java => PartitionStartRecord.java} | 61 ++++++++---------
...RecordTest.java => PartitionEndRecordTest.java} | 18 +++--
...cordTest.java => PartitionEventRecordTest.java} | 18 +++--
...cordTest.java => PartitionStartRecordTest.java} | 18 ++---
6 files changed, 110 insertions(+), 164 deletions(-)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecord.java
=> PartitionEndRecord.java} (51%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecord.java
=> PartitionEventRecord.java} (52%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecord.java
=> PartitionStartRecord.java} (62%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{HeartbeatRecordTest.java
=> PartitionEndRecordTest.java} (73%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{HeartbeatRecordTest.java
=> PartitionEventRecordTest.java} (72%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/{ChildPartitionsRecordTest.java
=> PartitionStartRecordTest.java} (72%)
