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

如何運行sparkStream早些時候(而不是未來的消息)

alejandrofm
價值貢獻

你好,我是聽一個流運動,不需要實時的數據,所以我可以運行它每小時的基礎上尋求達到兩件事:

保存錢沒有集群24/7

——為每個讀取大文件保存

流是不變的,我不能用一次= True,因為它永遠不會結束,我從桶用來閱讀。我們的想法是,它讀取到最後數據目前開始,然後優雅地退出。

這個可以做嗎?

謝謝!

2回答2

Kaniz
社區經理
社區經理

嗨@Alejandro馬丁內斯,在這裏S.O.有點類似問題請讓我們知道,幫助。

你好,謝謝你的鏈接時,該線程的解決方案是對卡夫卡和它似乎是一個不同的問題。

我需要停止這個過程達到當時可用的事件我開始傾聽,所以這個過程將完成當隊列是空的,但當我到達隊列上的一個特定的時間點。

謝謝!

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

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

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

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

Baidu
map