本申請提出一種數據處理方法和流計算系統,該數據處理方法包括數據接收模塊接收到要處理的數據后,將所述數據寫入文件系統中,并在所述數據被寫入文件系統后,發送所述數據給邏輯處理模塊;邏輯處理模塊根據對數據的接收情況獲取有效數據,并且,定期對預設的檢查點進行更新;以及,在發生失效轉移時,確定最新的檢查點,獲取與所述最新的檢查點對應的有效數據,并恢復所述有效數據。該方法能夠滿足對外服務化的訴求,以及在發生失效轉移時避免數據源頭重發。
聲明:
“數據處理方法和流計算系統” 該技術專利(論文)所有權利歸屬于技術(論文)所有人。僅供學習研究,如用于商業用途,請聯系該技術所有人。
我是此專利(論文)的發明人(作者)