initialOffset (SimpleDataSourceStreamReader)

Restituisce l'offset iniziale dell'origine dati di streaming.

Una nuova query di streaming inizia a leggere i dati dall'offset iniziale. Se Spark riavvia una query esistente, verrà riavviato dall'offset con checkpoint anziché da quello iniziale.

Aggiunta in Databricks Runtime 15.3

Sintassi

initialOffset()

Restituzioni

dict

Dict o dict ricorsivo il cui valore e la chiave sono tipi primitivi, che includono Integer, String e Boolean.

Examples

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