id (StreamingQuery)

Returnerar det unika ID:t för den här frågan som bevaras mellan omstarter från kontrollpunktsdata. ID:t genereras när en fråga startas för första gången och är samma varje gång den startas om från kontrollpunktsdata. Det kan bara finnas en fråga med samma ID aktivt i ett Spark-kluster.

Retur

str

Exempel

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