流水查询
最近进度
返回最近数组[[StreamingQuery进 更新进度更新数保留每一流由spark 会话配置spark.sql.streaming.numRecentProgressUpdates.
前一
pyspark.sql.streaming.StreamingQuery.processAllAvailable
下一个
pyspark.sql.streaming.StreamingQuery.runId