pyspark.sql.streaming.StreamingQuery

類 pyspark.sql.streaming。 StreamingQuery ( jsq:py4j.java_gateway.JavaObject )

處理一個查詢是在後台執行不斷新數據到來。所有這些方法都是線程安全的。

筆記

這個API是不斷發展的。

方法

awaitTermination((超時))	等待終止這查詢,通過query.stop ()或者是一個例外。
異常()	返回
解釋((擴展))	打印到控製台(邏輯和物理)計劃用於調試目的。
processAllAvailable()	直到所有可用的數據塊在源已經處理並致力於水槽。
停止()	停止這種流查詢。

屬性

id	返回這個查詢的惟一id從檢查點數據之間的重啟。
isActive	是否這個流查詢目前活躍。
lastProgress	返回最近的StreamingQueryProgress更新這個流的查詢或沒有如果沒有更新進展
的名字	返回指定的名稱查詢,如果未指定或null。
recentProgress	返回一個數組最近的[[StreamingQueryProgress]]更新查詢。
runId	返回這個查詢的惟一的id在重啟時不存在。
狀態	返回當前狀態的查詢。

以前的

pyspark.sql.streaming.DataStreamWriter

下一個

pyspark.sql.streaming.StreamingQueryManager