pyspark.sql.SparkSession.streams ¶

property SparkSession. streams ¶

返回一个 StreamingQueryManager ，用于管理在此上下文中所有活动的 StreamingQuery 实例。

新增于版本 2.0.0。

版本 3.5.0 更改：支持 Spark Connect。

Returns

StreamingQueryManager

注释

此API正在发展中。

示例

           >>> spark.streams
<pyspark...StreamingQueryManager object ...>

获取活跃的流查询列表

           >>> sq = spark.readStream.format(
...     "rate").load().writeStream.format('memory').queryName('this_query').start()
>>> sqm = spark.streams
>>> [q.name for q in sqm.active]
['this_query']
>>> sq.stop()

          

pyspark.sql.SparkSession.stop

pyspark.sql.SparkSession.table