get (StreamingQueryManager)

Vrátí aktivní streamovací dotaz z tohoto SparkSession dotazu podle jeho jedinečného ID.

Syntaxe

get(id)

Parametry

Parameter	Typ	Description
id	str	Jedinečné ID dotazu.

Návraty

StreamingQuery

Poznámky

Pokud aktivní dotaz s daným ID neexistuje, vyvolá se výjimka.

Příklady

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()