pyspark.sql.streaming.StreamingQueryListener¶
-
類
pyspark.sql.streaming。StreamingQueryListener¶ -
界麵聽相關的事件
StreamingQuery。筆記
的方法不是線程安全的,因為他們可能會從不同的線程調用。接收到的事件一致,Scala API。參考它的文檔。
這個API是不斷發展的。
例子
> > >類MyListener(StreamingQueryListener):…defonQueryStarted(自我,事件:QueryStartedEvent)- >沒有一個:…#做一些與事件。…通過……defonQueryProgress(自我,事件:QueryProgressEvent)- >沒有一個:…#做一些與事件。…通過……defonQueryTerminated(自我,事件:QueryTerminatedEvent)- >沒有一個:…#做一些與事件。…通過…> > >火花。流。addListener(MyListener())
方法
onQueryProgress(事件)當有一些狀態更新(攝入率更新等)。
onQueryStarted(事件)啟動時調用查詢。
onQueryTerminated(事件)當停止查詢,有或沒有錯誤。