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 |
|---|---|---|
| dict | Le dernier décalage que la query de streaming a traité pour cette source. |