ID (StreamingQuery)

Gibt die eindeutige ID dieser Abfrage zurück, die über Neustarts von Prüfpunktdaten hinweg beibehalten wird. Die ID wird generiert, wenn eine Abfrage zum ersten Mal gestartet wird, und ist jedes Mal gleich, wenn sie aus Prüfpunktdaten neu gestartet wird. Es kann nur eine Abfrage mit derselben ID vorhanden sein, die in einem Spark-Cluster aktiv ist.

Rückkehr

str

Beispiele

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