recentProgress （StreamingQuery）

返回此查询的最新 StreamingQueryProgress 更新的数组。 保留的进度更新数由配置 spark.sql.streaming.numRecentProgressUpdates。

退货

list of StreamingQueryProgress

示例

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.recentProgress
# [...]
sq.stop()