obter (StreamingQueryManager)

Retorna uma consulta de transmissão ativa deste SparkSession pelo seu ID único.

Sintaxe

get(id)

Parâmetros

Parâmetro	Tipo	Descrição
id	str	O ID único da consulta.

Devoluções

StreamingQuery

Notas

Uma exceção será lançada se não existir uma consulta ativa com o ID fornecido.

Exemplos

Python

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