Écriture
É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 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.
Ajouté dans Databricks Runtime 14.3 LTS
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.