recentProgress (StreamingQuery)

Devuelve una matriz de las actualizaciones más recientes StreamingQueryProgress de esta consulta. El número de actualizaciones de progreso conservadas se configura mediante spark.sql.streaming.numRecentProgressUpdates.

Devoluciones

list of StreamingQueryProgress

Ejemplos

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