本申請?zhí)岢鲆环N數(shù)據(jù)處理方法和流計算系統(tǒng),該數(shù)據(jù)處理方法包括數(shù)據(jù)接收模塊接收到要處理的數(shù)據(jù)后,將所述數(shù)據(jù)寫入文件系統(tǒng)中,并在所述數(shù)據(jù)被寫入文件系統(tǒng)后,發(fā)送所述數(shù)據(jù)給邏輯處理模塊;邏輯處理模塊根據(jù)對數(shù)據(jù)的接收情況獲取有效數(shù)據(jù),并且,定期對預(yù)設(shè)的檢查點進(jìn)行更新;以及,在發(fā)生失效轉(zhuǎn)移時,確定最新的檢查點,獲取與所述最新的檢查點對應(yīng)的有效數(shù)據(jù),并恢復(fù)所述有效數(shù)據(jù)。該方法能夠滿足對外服務(wù)化的訴求,以及在發(fā)生失效轉(zhuǎn)移時避免數(shù)據(jù)源頭重發(fā)。
聲明:
“數(shù)據(jù)處理方法和流計算系統(tǒng)” 該技術(shù)專利(論文)所有權(quán)利歸屬于技術(shù)(論文)所有人。僅供學(xué)習(xí)研究,如用于商業(yè)用途,請聯(lián)系該技術(shù)所有人。
我是此專利(論文)的發(fā)明人(作者)