runId (StreamingQuery)

Gibt die eindeutige ID dieser Abfrage zurück, die nicht über Neustarts hinweg beibehalten wird. Jede Abfrage, die gestartet wird (oder vom Prüfpunkt neu gestartet wird), weist eine andere runIdAufwertung auf.

Rückkehr

str

Beispiele

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