write (DataSourceStreamWriter)

Écrit des 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 microbatch. Il accepte un itérateur de données d’entrée et retourne une seule ligne représentant un message de validation, ou None s’il n’existe aucun message de validation.

Le pilote collecte les messages de validation, le cas échéant, de tous les exécuteurs et les transmet à la commit() méthode si toutes les tâches s’exécutent correctement. Si une tâche échoue, la abort() méthode est appelée avec les messages de validation collectés.

Syntaxe

write(iterator: Iterator[Row])

Paramètres

Retours

WriterCommitMessage

Message de validation sérialisable.