initialOffset (DataSourceStreamReader)

Vrátí počáteční posun streamovaného zdroje dat.

Nový streamovací dotaz začne číst data z počátečního posunu. Pokud Spark restartuje existující dotaz, restartuje se z kontrolního posunu, nikoli z počátečního dotazu.

Přidáno do Databricks Runtime 15.2

Syntaxe

initialOffset()

Návraty

dict

Diktování nebo rekurzivní diktování, jehož klíč a hodnota jsou primitivní typy, včetně integer, String a Boolean.

Příklady

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