pyspark.sql.streaming.StreamingQueryManager

類 pyspark.sql.streaming。 StreamingQueryManager ( jsqm:py4j.java_gateway.JavaObject )

一個類來管理的StreamingQueryStreamingQueries活躍。

筆記

這個API是不斷發展的。

方法

addListener(聽眾)	注冊一個StreamingQueryListener接收返回值的生命周期事件StreamingQuery。
awaitAnyTermination((超時))	等到任何的查詢相關SQLContext終止自創建上下文,或自resetTerminated ()被稱為。
得到(id)	返回一個活躍的查詢從這個SQLContext或拋出異常活躍的查詢與這個名字並不存在。
removeListener(聽眾)	取消注冊StreamingQueryListener。
resetTerminated()	忘記過去的終止,以便查詢awaitAnyTermination ()可以再次等待新終端使用。

屬性

活躍的	返回一個列表的活躍與此SQLContext相關查詢

以前的

pyspark.sql.streaming.StreamingQuery

下一個

pyspark.sql.streaming.StreamingQueryListener