initialOffset (SimpleDataSourceStreamReader)

Returnerar den första förskjutningen av den strömmande datakällan.

En ny direktuppspelningsfråga börjar läsa data från den första förskjutningen. Om Spark startar om en befintlig fråga startas den om från förskjutningen med kontrollpunkter i stället för den första.

Har lagts till i Databricks Runtime 15.3

Syntax

initialOffset()

Retur

dict

En diktering eller rekursiv diktering vars nyckel och värde är primitiva typer, som innehåller Heltal, Sträng och Booleskt värde.

Exempel

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