initialOffset (SimpleDataSourceStreamReader)

Devuelve el desplazamiento inicial del origen de datos de streaming.

Una nueva consulta de streaming comienza a leer datos del desplazamiento inicial. Si Spark reinicia una consulta existente, se reiniciará desde el desplazamiento de punto de control en lugar del inicial.

Agregado en Databricks Runtime 15.3

Sintaxis

initialOffset()

Devoluciones

dict

Un dict o dict recursive cuya clave y valor son tipos primitivos, que incluye Integer, String y Boolean.

Ejemplos

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