write (DataSourceStreamWriter)

Scrive i dati nel sink di streaming.

Questo metodo viene chiamato su executor per scrivere dati nel sink di dati di streaming in ogni microbatch. 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.

Sintassi

write(iterator: Iterator[Row])

Parametri

Restituzioni

WriterCommitMessage

Messaggio di commit serializzabile.