一阶段只实现采集数据的原样存储及推送 二阶段的目前是实现真正的“微数据”,加入数据分析聚合能力,并向上只暴露处理后的微数据,这样可直接对接上层应用。 要实现此能力主要关注:引入Spark SQL用于数据分析,开发模型库用于常用模型处理,引用Spark MLlib实现常用的算法处理