commit (SimpleDataSourceStreamReader)

Informe la source que Spark a terminé de traiter toutes les données pour les décalages inférieurs ou égaux à end et demande uniquement des décalages supérieurs end à ceux à venir.

Ajouté dans Databricks Runtime 15.3

Syntaxe

commit(end: dict)

Paramètres

Paramètre Type Description
end dictionnaire Décalage le plus récent que la requête de diffusion en continu a traité pour cette source.