StreamingQuery。
recentProgress
返回一個數組最近的[[StreamingQueryProgress]]更新查詢。進展更新留存的數量為每個流配置通過火花會話配置spark.sql.streaming.numRecentProgressUpdates。
以前的
pyspark.sql.streaming.StreamingQuery.processAllAvailable
下一個
pyspark.sql.streaming.StreamingQuery.runId