recentProgress (StreamingQuery)

Mengembalikan array pembaruan terbaru StreamingQueryProgress untuk kueri ini. Jumlah pembaruan kemajuan yang dipertahankan dikonfigurasi oleh spark.sql.streaming.numRecentProgressUpdates.

Pengembalian Barang

list of StreamingQueryProgress

Examples

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