id (StreamingQuery)

Bu sorgunun denetim noktası verilerinden yeniden başlatmalar arasında kalıcı olan benzersiz kimliğini döndürür. Kimlik, sorgu ilk kez başlatıldığında oluşturulur ve denetim noktası verilerinden her yeniden başlatıldığında aynı olur. Spark kümesinde aynı kimliğin etkin olduğu yalnızca bir sorgu olabilir.

İadeler

str

Örnekler

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