public void updateDetectNewPartitionWatermark(Instant watermark) {
    writeToMdTableWatermarkHelper(getFullDetectNewPartition(), watermark, null);
  }
@Test
  public void testUpdateDetectNewPartitionWatermark() {
    Instant watermark = Instant.now();
    metadataTableDao.updateDetectNewPartitionWatermark(watermark);
    Row row =
        dataClient.readRow(
            metadataTableAdminDao.getTableId(),
            metadataTableDao
                .getChangeStreamNamePrefix()
                .concat(MetadataTableAdminDao.DETECT_NEW_PARTITION_SUFFIX));
    assertNull(MetadataTableEncoder.parseTokenFromRow(row));
    assertEquals(watermark, parseWatermarkFromRow(row));
  }