基于批流一體的數(shù)據(jù)處理方法、裝置、計(jì)算機(jī)設(shè)備和介質(zhì)

基本信息

申請(qǐng)?zhí)?/td> CN202111318823.5 申請(qǐng)日 -
公開（公告）號(hào) CN113779094B 公開（公告）日 2022-03-22
申請(qǐng)公布號(hào) CN113779094B 申請(qǐng)公布日 2022-03-22
分類號(hào) G06F16/2455（2019.01）I;G06F16/25（2019.01）I;G06F16/28（2019.01）I 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 王博一;王曉;霍星志;郭宇鵬;毛少將 申請(qǐng)（專利權(quán)）人 通號(hào)通信信息集團(tuán)有限公司
代理機(jī)構(gòu) 北京天昊聯(lián)合知識(shí)產(chǎn)權(quán)代理有限公司 代理人 彭瑞欣;姜春咸
地址 100070北京市豐臺(tái)區(qū)汽車博物館南路1號(hào)院中國通號(hào)大廈A座601室
法律狀態(tài) -

摘要

摘要 本公開提供一種基于批流一體的數(shù)據(jù)處理方法，所述方法應(yīng)用于數(shù)據(jù)處理裝置，數(shù)據(jù)處理裝置包括數(shù)據(jù)應(yīng)用層和多個(gè)處理層，各處理層形成處理鏈路，所述方法包括：獲取待處理數(shù)據(jù)；根據(jù)處理鏈路逐層處理待處理數(shù)據(jù)，得到第一數(shù)據(jù)；其中，在各處理層中，對(duì)輸入本處理層的數(shù)據(jù)進(jìn)行處理，將處理后的數(shù)據(jù)輸入至下一個(gè)處理層；在數(shù)據(jù)應(yīng)用層中處理第一數(shù)據(jù)，得到第二數(shù)據(jù)；響應(yīng)于檢測出第二數(shù)據(jù)發(fā)生數(shù)據(jù)錯(cuò)誤，在發(fā)生數(shù)據(jù)錯(cuò)誤的處理層中，根據(jù)本處理層的離線數(shù)據(jù)對(duì)發(fā)生數(shù)據(jù)錯(cuò)誤的數(shù)據(jù)進(jìn)行修正，將修正后的數(shù)據(jù)輸入至下一個(gè)處理層，以便下一個(gè)處理層對(duì)輸入的數(shù)據(jù)進(jìn)行處理。本公開還提供一種數(shù)據(jù)處理裝置、計(jì)算機(jī)設(shè)備和介質(zhì)。