一種用于軌道交通多源流數(shù)據(jù)的分布式實(shí)時(shí)處理方法
基本信息
| 申請(qǐng)?zhí)?/td> | CN201910350049.2 | 申請(qǐng)日 | - |
| 公開(kāi)（公告）號(hào) | CN110096520B | 公開(kāi)（公告）日 | 2021-08-17 |
| 申請(qǐng)公布號(hào) | CN110096520B | 申請(qǐng)公布日 | 2021-08-17 |
| 分類(lèi)號(hào) | G06F16/2455 | 分類(lèi) | 計(jì)算；推算；計(jì)數(shù); |
| 發(fā)明人 | 高楊;王剛;黃滔;鮑迪恩 | 申請(qǐng)（專利權(quán)）人 | 浙江邦盛科技股份有限公司 |
| 代理機(jī)構(gòu) | 杭州求是專利事務(wù)所有限公司 | 代理人 | 劉靜;邱啟旺 |
| 地址 | 310012 浙江省杭州市西湖區(qū)西斗門(mén)路3號(hào)天堂軟件園D幢17層ABCD座 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本發(fā)明公開(kāi)了一種用于軌道交通多源流數(shù)據(jù)的分布式實(shí)時(shí)處理方法，該方法包括多源流數(shù)據(jù)的合并和合并后流數(shù)據(jù)的分布式處理兩部分；多源流數(shù)據(jù)的合并首先對(duì)同一軌道線路上同一車(chē)輛的實(shí)時(shí)數(shù)據(jù)進(jìn)行維度上的合并，對(duì)維度合并后得到的新流進(jìn)行廣度上的合并；合并后流數(shù)據(jù)的分布式處理在分布式系統(tǒng)上實(shí)現(xiàn)，分布式系統(tǒng)擁有兩種類(lèi)型的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)了完全的分布式處理。 |
