write (DataSourceStreamWriter)

Akış havuzuna veri yazar.

Bu yöntem, yürütücülerde her mikrobatch'teki akış veri havuzuna veri yazmak için çağrılır. Giriş verilerinin yineleyicisini kabul eder ve işleme iletisini temsil eden veya None işleme iletisi olmayan tek bir satır döndürür.

Sürücü varsa, tüm yürütücülerden işleme iletilerini toplar ve tüm görevler başarıyla çalıştırılırsa bunları yöntemine commit() geçirir. Herhangi bir görev başarısız olursa, abort() yöntemi toplanan işleme iletileriyle çağrılır.

Sözdizimi

write(iterator: Iterator[Row])

Parametreler

Parametre	Türü	Açıklama
iterator	Yineleyici[Satır]	Giriş verilerinin yineleyicisi.

İadeler

WriterCommitMessage

Seri hale getirilebilir bir işleme iletisi.