écriture (DataSourceStreamWriter)
Écrit les données dans le récepteur de streaming.
Cette méthode est appelée sur les exécuteurs pour écrire des données dans le récepteur de données de streaming dans chaque micro-lot. Il accepte un itérateur de données d'entrée et renvoie une seule ligne représentant un message de commit, ou None s'il n'y a pas de message de commit.
Le Driver recueille les messages de commit, le cas échéant, de tous les exécuteurs et les transmet à la méthode commit() si toutes les tâches s'exécutent correctement. Si une tâche échoue, la méthode abort() sera appelée avec les messages de commit recueillis.
Syntaxe
write(iterator: Iterator[Row])
parameter
parameter | Type | Description |
|---|---|---|
| Itérateur[Ligne] | Un itérateur de données d'entrée. |
Renvoie
WriterCommitMessage
Un message de commit sérialisable.