schrijven (DataSourceStreamWriter)

Hiermee schrijft u gegevens naar de streaming-sink.

Deze methode wordt aangeroepen voor uitvoerders om gegevens te schrijven naar de sink voor streaminggegevens in elke microbatch. Het accepteert een iterator van invoergegevens en retourneert één rij die een doorvoerbericht vertegenwoordigt of None als er geen doorvoerbericht is.

Het stuurprogramma verzamelt doorvoerberichten van alle uitvoerders en geeft deze door aan de commit() methode als alle taken zijn uitgevoerd. Als een taak mislukt, wordt de abort() methode aangeroepen met de verzamelde doorvoerberichten.

Syntaxis

write(iterator: Iterator[Row])

Parameterwaarden

Retouren

WriterCommitMessage

Een serialiseerbare doorvoeringsbericht.