scrivi

Scrive i dati nell'origine dati.

Questo metodo viene chiamato una volta su ogni executor per scrivere dati nell'origine dati. Accetta un iteratore di dati di input e restituisce una singola riga che rappresenta un messaggio di commit o None se non è presente alcun messaggio di commit.

Il driver raccoglie i messaggi di commit, se presenti, da tutti gli executor e li passa al commit() metodo se tutte le attività vengono eseguite correttamente. Se un'attività ha esito negativo, il abort() metodo verrà chiamato con i messaggi di commit raccolti.

Aggiunta in Databricks Runtime 14.3 LTS

Sintassi

write(iterator: Iterator[Row])

Parametri

Restituzioni

WriterCommitMessage

Messaggio di commit serializzabile.