read (SimpleDataSourceStreamReader)
Lit toutes les données disponibles à partir du décalage de start et renvoie le décalage à partir duquel la prochaine tentative de lecture démarre.
Ajouté dans Databricks Runtime 15.3
Syntaxe
read(start: dict)
parameter
parameter | Type | Description |
|---|---|---|
| dict | L'offset de start à partir duquel lire. |
Renvoie
Tuple[Iterator[Tuple], dict]
Un tuple d'un itérateur et d'un dictionnaire. L'itérateur contient tous les enregistrements disponibles après le décalage de start. Le dictionnaire est le décalage de fin de cette tentative de lecture et le décalage de start de la prochaine tentative de lecture.