Aller au contenu principal

commit (DataSourceStreamReader)

Informe la source que Spark a terminé le traitement de toutes les données pour les décalages inférieurs ou égaux à end et ne demandera que les décalages supérieurs à end à l'avenir.

Ajouté dans Databricks Runtime 15.2

Syntaxe

commit(end: dict)

parameter

parameter

Type

Description

end

dict

Le dernier décalage que la query de streaming a traité pour cette source.

parameter

Type

Description

end

dict

Le dernier décalage que la query de streaming a traité pour cette source.

Sur cette page