pyspark.sql.streaming.StreamingQuery.processAllAvailable

StreamingQuery。 processAllAvailable ( )→沒有

直到所有可用的數據塊在源已經處理並致力於水槽。該方法用於測試。

筆記

對於連續到達的數據,這種方法可能會阻止,直到永遠。此外,這種方法隻是保證阻塞,直到數據同步附加數據流源之前調用。(即。getOffset必須立即反映之外)。

以前的

pyspark.sql.streaming.StreamingQuery.name

下一個

pyspark.sql.streaming.StreamingQuery.recentProgress