基于分布式計(jì)算框架的全局排序輸出系統(tǒng)及其方法

基本信息

申請(qǐng)?zhí)?/td> CN202011413983.3 申請(qǐng)日 -
公開(公告)號(hào) CN112540985A 公開(公告)日 2021-03-23
申請(qǐng)公布號(hào) CN112540985A 申請(qǐng)公布日 2021-03-23
分類號(hào) G06F16/22(2019.01)I;G06F16/27(2019.01)I 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 孫振 申請(qǐng)(專利權(quán))人 江蘇賽融科技股份有限公司
代理機(jī)構(gòu) 北京同輝知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 代理人 廖娜
地址 210000江蘇省南京市浦口區(qū)浦濱大道320號(hào)科創(chuàng)廣場科技創(chuàng)新總部大廈B座2406室
法律狀態(tài) -

摘要

摘要 本發(fā)明涉及一種基于分布式計(jì)算框架的全局排序輸出系統(tǒng)及其方法,采用分布式計(jì)算框架,其內(nèi)設(shè)置有節(jié)點(diǎn)排序暫存模塊、共識(shí)數(shù)據(jù)排序模塊、數(shù)據(jù)同步輸出模塊。通過節(jié)點(diǎn)排序暫存模塊用于數(shù)據(jù)排序,通過共識(shí)數(shù)據(jù)排序模塊,將排序后的數(shù)據(jù)傳遞到下一個(gè)步驟,通過數(shù)據(jù)同步輸出模塊,將數(shù)據(jù)輸出至目標(biāo)庫表。由此,各個(gè)節(jié)點(diǎn)通過共識(shí)輪詢?nèi)謹(jǐn)?shù)據(jù)排序,不需要依賴分布式文件系統(tǒng)進(jìn)行全局排序,簡化了系統(tǒng)的復(fù)雜度。不需要將數(shù)據(jù)集中起來處理,降低了內(nèi)存、CPU等資源消耗。整個(gè)排序過程耗時(shí)少,處理效率高,能更快的寫入目標(biāo)庫表,提高用戶體驗(yàn)。減少網(wǎng)絡(luò)消耗,降低分布式計(jì)算框架資源消耗。??