spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From RanXin <ranxi...@163.com>
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
function:
def process_row(row):
          # Write row to storage
          pass
      
query = streamingDF.writeStream.foreach(process_row).start()

Thanks a lot.



--
Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/

---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscribe@spark.apache.org


Mime
View raw message