get (StreamingQueryManager)

Devuelve una consulta de streaming activa de esta SparkSession por su identificador único.

Sintaxis

get(id)

Parámetros

Parámetro	Tipo	Descripción
id	str	Identificador único de la consulta.

Devoluciones

StreamingQuery

Notas

Se produce una excepción si no existe una consulta activa con el identificador especificado.

Ejemplos

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