get (StreamingQueryManager)

Возвращает активный потоковый запрос из этого SparkSession по уникальному идентификатору.

Синтаксис

get(id)

Параметры

Параметр	Тип	Описание
id	str	Уникальный идентификатор запроса.

Возвраты

StreamingQuery

Примечания

Исключение возникает, если активный запрос с заданным идентификатором не существует.

Примеры

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