initialOffset (DataSourceStreamReader)

Gibt den anfänglichen Offset der Streamingdatenquelle zurück.

Eine neue Streamingabfrage beginnt mit dem Lesen von Daten aus dem anfänglichen Offset. Wenn Spark eine vorhandene Abfrage neu startet, wird sie vom prüfpunktierten Offset und nicht vom ursprünglichen neu gestartet.

Hinzugefügt in Databricks Runtime 15.2

Syntax

initialOffset()

Rückkehr

dict

Ein Diktat oder rekursives Diktat, dessen Schlüssel und Wert grundtyptyp sind, einschließlich Integer, String und Boolean.

Beispiele

def initialOffset(self):
    return {"partition-1": {"index": 3, "closed": True}, "partition-2": {"index": 5}}