get (StreamingQueryManager)

Bu SparkSession sorgudan benzersiz kimliğine göre etkin bir akış sorgusu döndürür.

Sözdizimi

get(id)

Parametreler

Parametre	Türü	Açıklama
id	str	Sorgunun benzersiz kimliği.

İadeler

StreamingQuery

Notlar

Verilen kimlikle etkin bir sorgu yoksa bir özel durum oluşturulur.

Örnekler

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