lastProgress (StreamingQuery)

Retourne la mise à jour la plus récente StreamingQueryProgress de cette requête de diffusion en continu, ou None s’il n’y a pas eu de mises à jour de progression.

Retours

StreamingQueryProgress ou None

Exemples

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.lastProgress
sq.stop()