spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From RanXin <>
Subject Structured Streaming foreach function
Date Sun, 23 Jun 2019 09:14:54 GMT
I use spark 2.4.3, python to build a structured streaming. May I know the
data type of the parameter "row" in process_row function? The following
codes is how the official programming guide instruct us to deal with foreach
def process_row(row):
          # Write row to storage
query = streamingDF.writeStream.foreach(process_row).start()

Thanks a lot.

Sent from:

To unsubscribe e-mail:

View raw message