get (StreamingQueryManager)

Restituisce una query di streaming attiva da questo SparkSession oggetto in base al relativo ID univoco.

Sintassi

get(id)

Parametri

Restituzioni

StreamingQuery

Note

Viene generata un'eccezione se non esiste una query attiva con l'ID specificato.

Examples

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