initialOffset (DataSourceStreamReader)

Renvoie l'offset initial de la source de données de streaming.

Une nouvelle requête de streaming commence à lire des données à partir du décalage initial. Si Spark redémarre une query existante, il redémarrera à partir du décalage de point de contrôle plutôt que du décalage initial.

Ajouté dans Databricks Runtime 15.2

Syntaxe

initialOffset()

Renvoie

dict

Un dictionnaire ou un dictionnaire récursif dont la clé et la valeur sont des types primitifs, ce qui inclut les entiers, les chaînes de caractères et les booléens.

Exemples

Python

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