écrire

Écrit des données dans la source de données.

Cette méthode est appelée une fois sur chaque exécuteur pour écrire des données dans la source de données. 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.

Ajouté dans Databricks Runtime 14.3 LTS

Syntaxe

write(iterator: Iterator[Row])

Paramètres

Paramètre Type Description
iterator Itérateur[ligne] Itérateur de données d’entrée.

Retours

WriterCommitMessage

Message de validation sérialisable.