id (StreamingQuery)

Mengembalikan ID unik kueri ini yang bertahan di seluruh mulai ulang dari data titik pemeriksaan. ID dihasilkan ketika kueri dimulai untuk pertama kalinya, dan sama setiap kali dimulai ulang dari data titik pemeriksaan. Hanya ada satu kueri dengan ID yang sama aktif di kluster Spark.

Pengembalian Barang

str

Examples

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