initialOffset (SimpleDataSourceStreamReader)

Retourneert de eerste offset van de streaminggegevensbron.

Een nieuwe streamingquery begint met het lezen van gegevens vanaf de eerste offset. Als Spark een bestaande query opnieuw start, wordt deze opnieuw opgestart vanaf de controlepunt-offset in plaats van de eerste.

Toegevoegd in Databricks Runtime 15.3

Syntaxis

initialOffset()

Retouren

dict

Een dict of recursieve dict waarvan de sleutel en waarde primitieve typen zijn, waaronder Geheel getal, Tekenreeks en Booleaanse waarde.

Examples

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