取消
顯示的結果
而不是尋找
你的意思是:

spark.apache.org

Sandeep
貢獻者三世

每API文檔StreamingQuery.stop (),

https://spark.apache.org/docs/latest/api/scala/org/apache/spark/sql/streaming/StreamingQuery.html

它說,這將停止執行這個查詢如果是跑步和等待,直到查詢執行線程的終止或直到超時。

這並不意味著它等待micro-batch完成。它將中斷所有活動線程,但等到終止或完成如果不中斷當前線程運行。有時候我們使用不間斷線程,例如與卡夫卡——因為打斷卡夫卡線程磚集群。所有其他線程將被打斷。

0回答0
歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map