initialOffset (DataSourceStreamReader)

Retorna o deslocamento inicial da fonte de dados de streaming.

Uma nova consulta de streaming inicia a leitura de dados do deslocamento inicial. Se o Spark estiver reiniciando uma consulta existente, ela será reiniciada do deslocamento com ponto de verificação em vez da inicial.

Adicionado no Databricks Runtime 15.2

Sintaxe

initialOffset()

Devoluções

dict

Um ditado dict ou recursivo cuja chave e valor são tipos primitivos, que inclui Inteiro, Cadeia de Caracteres e Booleano.

Exemplos

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