pyspark.sql.streaming.StreamingQuery.stop

StreamingQuery. stop ( ) → None

停止此流查询。

新增于版本 2.0.0。

版本 3.5.0 更改： 支持 Spark Connect。

示例

>>> sdf = spark.readStream.format("rate").load()
>>> sq = sdf.writeStream.format('memory').queryName('this_query').start()
>>> sq.isActive
True

停止流式查询

>>> sq.stop()

>>> sq.isActive
False

上一篇

pyspark.sql.streaming.StreamingQuery.状态

下一页

pyspark.sql.streaming.StreamingQueryManager.active