Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
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()