一種用于軌道交通多源流數(shù)據(jù)的分布式實(shí)時(shí)處理方法

基本信息

申請(qǐng)?zhí)?/td> CN201910350049.2 申請(qǐng)日 -
公開（公告）號(hào) CN110096520A 公開（公告）日 2019-08-06
申請(qǐng)公布號(hào) CN110096520A 申請(qǐng)公布日 2019-08-06
分類號(hào) G06F16/2455 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 高楊;王剛;黃滔;鮑迪恩 申請(qǐng)（專利權(quán)）人 浙江邦盛科技股份有限公司
代理機(jī)構(gòu) 杭州求是專利事務(wù)所有限公司 代理人 浙江邦盛科技有限公司;中車唐山機(jī)車車輛有限公司
地址 310012 浙江省杭州市西湖區(qū)西斗門路3號(hào)天堂軟件園D幢17層ABCD座
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種用于軌道交通多源流數(shù)據(jù)的分布式實(shí)時(shí)處理方法，該方法包括多源流數(shù)據(jù)的合并和合并后流數(shù)據(jù)的分布式處理兩部分；多源流數(shù)據(jù)的合并首先對(duì)同一軌道線路上同一車輛的實(shí)時(shí)數(shù)據(jù)進(jìn)行維度上的合并，對(duì)維度合并后得到的新流進(jìn)行廣度上的合并；合并后流數(shù)據(jù)的分布式處理在分布式系統(tǒng)上實(shí)現(xiàn)，分布式系統(tǒng)擁有兩種類型的Manager，分別為JobManager以及TaskManager；設(shè)置多個(gè)JobManager；本發(fā)明具有一定的伸縮度，且整個(gè)架構(gòu)的伸縮不會(huì)降低或增加整體的流處理計(jì)算量；本發(fā)明擁有性能高的特點(diǎn)；本發(fā)明在進(jìn)行分布式處理時(shí)，采用了分布式多JobManager狀態(tài)同步的方式實(shí)現(xiàn)了完全的分布式處理。