initialOffset (SimpleDataSourceStreamReader)

Retourne le décalage initial de la source de données de streaming.

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

Ajouté dans Databricks Runtime 15.3

Syntaxe

initialOffset()

Retours

dict

dictée ou récursive dont la clé et la valeur sont des types primitifs, qui inclut Integer, String et Boolean.

Exemples

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