Incremental Extraction Watermark

Track incremental extraction progress, handle timestamp ties and late commits, and advance the checkpoint only after the destination commits.