deslocamento inicial (SimpleDataSourceStreamReader)

Retorna o deslocamento inicial da transmissão fonte de dados.

Uma nova consulta de transmissão começa a ler os dados do deslocamento inicial. Se o Spark estiver reiniciando uma consulta existente, ele reiniciará a partir do ponto de verificação (checkpoint) em vez do ponto inicial.

Adicionado no Databricks Runtime 15.3

Sintaxe

initialOffset()

Devoluções

dict

Um dicionário ou dicionário recursivo cuja key e valor são tipos primitivos, incluindo Integer, strings e Boolean.

Exemplos

Python

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