initialOffset (SimpleDataSourceStreamReader)

Devolve o deslocamento inicial da fonte de dados em streaming.

Uma nova consulta de streaming começa a ler dados a partir do deslocamento inicial. Se o Spark estiver a reiniciar uma consulta existente, irá reiniciar a partir do deslocamento checkpoint em vez do inicial.

Adicionado no Databricks Runtime 15.3

Sintaxe

initialOffset()

Devoluções

dict

Um dict ou dict recursivo cuja chave e valor são tipos primitivos, incluindo Inteiro, String e Booleano.

Exemplos

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