一种基于流式大数据的交通态势实时计算方法

摘要

本发明公开了一种基于流式大数据的交通态势实时计算方法，包括构建基于Spark Streaming与Kafka的分布式航迹流数据处理平台、Online Learning复杂度评估模型。通过本发明的技术方案，能够通过流式大数据框架实现航迹数据与扇区指标数据的在线转换，并通过改进评估算法，使其能满足在线评估的要求，实现实时的扇区复杂度评估。