一種實(shí)時(shí)分布式數(shù)據(jù)監(jiān)聽(tīng)方法

基本信息

申請(qǐng)?zhí)?/td> CN202010910210.X 申請(qǐng)日 -
公開(kāi)(公告)號(hào) CN112068933B 公開(kāi)(公告)日 2021-08-10
申請(qǐng)公布號(hào) CN112068933B 申請(qǐng)公布日 2021-08-10
分類(lèi)號(hào) G06F9/455;G06F11/30;G06F16/2458 分類(lèi) 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 朱帥;劉博;張?chǎng)?于開(kāi)進(jìn) 申請(qǐng)(專利權(quán))人 成都魚(yú)泡科技有限公司
代理機(jī)構(gòu) 北京天奇智新知識(shí)產(chǎn)權(quán)代理有限公司 代理人 許馳
地址 610000 四川省成都市中國(guó)(四川)自由貿(mào)易試驗(yàn)區(qū)成都高新區(qū)益州大道中段1858號(hào)3F
法律狀態(tài) -

摘要

摘要 本發(fā)明提供了一種實(shí)時(shí)分布式數(shù)據(jù)監(jiān)聽(tīng)方法,所述方法包括:在掃描階段對(duì)所收到的部分事務(wù)數(shù)據(jù)執(zhí)行分類(lèi)處理。對(duì)多個(gè)事務(wù)數(shù)據(jù)進(jìn)行統(tǒng)計(jì)產(chǎn)生各數(shù)據(jù)項(xiàng)的累計(jì)次數(shù),判斷各數(shù)據(jù)項(xiàng)是否為頻繁項(xiàng);若確定某項(xiàng)數(shù)據(jù)為頻繁項(xiàng),將數(shù)據(jù)項(xiàng)及累計(jì)次數(shù)寫(xiě)入分布式區(qū)塊文件;通過(guò)分布式區(qū)塊文件記錄所有頻繁項(xiàng)及累計(jì)次數(shù);在分析挖掘階段從分布式區(qū)塊文件中選擇部分頻繁項(xiàng)來(lái)建立特定數(shù)量的節(jié)點(diǎn);根據(jù)分布式區(qū)塊文件判斷否為頻繁序列模式數(shù)據(jù)。本發(fā)明提出了一種實(shí)時(shí)分布式數(shù)據(jù)監(jiān)聽(tīng)方法,通過(guò)高實(shí)時(shí)性的應(yīng)用和服務(wù)提高了分布式海量異構(gòu)數(shù)據(jù)的分析挖掘處理性能。