一种用于轨道交通多源流数据的分布式实时处理方法

摘要

本发明公开了一种用于轨道交通多源流数据的分布式实时处理方法，该方法包括多源流数据的合并和合并后流数据的分布式处理两部分；多源流数据的合并首先对同一轨道线路上同一车辆的实时数据进行维度上的合并，对维度合并后得到的新流进行广度上的合并；合并后流数据的分布式处理在分布式系统上实现，分布式系统拥有两种类型的Manager，分别为JobManager以及TaskManager；设置多个JobManager；本发明具有一定的伸缩度，且整个架构的伸缩不会降低或增加整体的流处理计算量；本发明拥有性能高的特点；本发明在进行分布式处理时，采用了分布式多JobManager状态同步的方式实现了完全的分布式处理。