id (StreamingQuery)

Zwraca unikatowy identyfikator tego zapytania, który utrzymuje się po ponownym uruchomieniu z danych punktu kontrolnego. Identyfikator jest generowany po pierwszym uruchomieniu zapytania i jest taki sam przy każdym ponownym uruchomieniu z danych punktu kontrolnego. W klastrze Spark może istnieć tylko jedno zapytanie o tym samym identyfikatorze.

Zwroty

str

Examples

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