Condividi tramite


readBetweenOffsets (SimpleDataSourceStreamReader)

Legge tutti i dati disponibili tra uno specifico offset iniziale e un offset finale.

Questo metodo viene richiamato durante il ripristino degli errori per rileggere un batch in modo deterministico.

Aggiunta in Databricks Runtime 15.3

Sintassi

readBetweenOffsets(start: dict, end: dict)

Parametri

Parametro Tipo Descrizione
start dizionario Offset iniziale da cui leggere.
end dizionario Offset in corrispondenza del quale viene interrotta la lettura.

Restituzioni

Iterator[Tuple]

Tutti i record tra l'offset iniziale e l'offset finale.