Test

Author: chenxuesdu

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/PartitionMetadataDao.java

@@ -597,6 +597,8 @@ public Void updateWatermark(String partitionToken, Timestamp watermark) {
      * @return the watermark for the given token if it exists. Otherwise, it returns null.
      */
     public @Nullable Timestamp getWatermarkForPartition(String partitionToken) {
+      Struct row =
+   *             transaction.readRow(metadataTableName, Key.of(singerId), Collections.singleton(column));
       final Statement statement;
       if (this.dialect == Dialect.POSTGRESQL) {
         statement =