Freigeben über


commit (DataSourceStreamReader)

Informiert die Quelle, dass Spark die Verarbeitung aller Daten für Offsets abgeschlossen hat, die kleiner oder gleich end sind, und fordert nur Offsets an, die höher sind als end in der Zukunft.

Hinzugefügt in Databricks Runtime 15.2

Syntax

commit(end: dict)

Parameter

Parameter Typ Beschreibung
end Wörterbuch Der neueste Offset, den die Streamingabfrage für diese Quelle verarbeitet hat.