def METHOD_NAME(self) -> Iterator[RDSModel]:
    """
    Create watermark records
    """
    for part in self.parts:
        part_record = RDSTableWatermark(
            rk=self.get_watermark_model_key(),
            partition_key=part[0],
            partition_value=part[1],
            create_time=self.create_time,
            table_rk=self.get_metadata_model_key()
        )
        yield part_record