Aller au contenu principal

readBetweenOffsets (SimpleDataSourceStreamReader)

Lit toutes les données disponibles entre un décalage de start et un décalage de fin spécifiques.

Cette méthode est invoquée pendant la récupération après échec pour relire un batch de manière déterministe.

Ajouté dans Databricks Runtime 15.3

Syntaxe

readBetweenOffsets(start: dict, end: dict)

parameter

parameter

Type

Description

start

dict

L'offset de start à partir duquel lire.

end

dict

Le décalage auquel la lecture s'arrête.

parameter

Type

Description

start

dict

L'offset de start à partir duquel lire.

end

dict

Le décalage auquel la lecture s'arrête.

Renvoie

Iterator[Tuple]

Tous les enregistrements entre le décalage de start et le décalage de fin.