Un watermark est la valeur mémorisée, comme la date de dernière modification traitée, qui marque jusqu'où le pipeline a lu. Au passage suivant, on ne charge que les lignes postérieures : c'est le principe du chargement incrémental. Il doit être mis à jour seulement après un chargement réussi.
Exemple
SELECT * FROM commandes WHERE modifie_le > :dernier_watermark