CN111158953B 一种车辆数据实时聚集方法 （陕西天行健车联网信息技术有限公司）_第1页
CN111158953B 一种车辆数据实时聚集方法 （陕西天行健车联网信息技术有限公司）_第2页
CN111158953B 一种车辆数据实时聚集方法 （陕西天行健车联网信息技术有限公司）_第3页
CN111158953B 一种车辆数据实时聚集方法 （陕西天行健车联网信息技术有限公司）_第4页
CN111158953B 一种车辆数据实时聚集方法 （陕西天行健车联网信息技术有限公司）_第5页
已阅读5页，还剩10页未读， 继续免费阅读

下载本文档

版权说明：本文档由用户提供并上传，收益归属内容提供方，若内容存在侵权，请进行举报或认领

文档简介

城陕汽大道1号技术中心大楼3层301室然后在基于kafka无界流分窗口汇总数据结果，果分别缓存到redis存储，从而可持续地写入运久化总共时间控制在延迟10分钟以内；与T+1汇2所述车辆中间数据缓存到Redis时，将车辆的起始业务状态保存在Redis2.如权利要求1所述的车辆数据实时聚集方法，其理全局变量中产生时间靠前的历史数据以降低占用比到1)iov_task_api提供面向任务的接口，其包括Def3(比如hdfs)存储，经过T+1的时间(即当天只能计算出前一天的数据汇总)，得到汇总的结[0011]所述车辆中间数据缓存到Redis时，将车辆的起始业务状态保[0012]所述的Redis还设有定时清理历史数据的定时清理器：定时清理器按照设定的时[0013]所述的Redis还设有变量监控器，以对在写入缓存期间或运算期间产生的全局变4[0016]1)iov_task_api提供面向任务的接口，其包括DefaultScheduleTask类和[0021]本发明提供的车辆数据实时聚集方法，针对跨窗口的初始业务变量对象采用[0029]下面结合实施例对本发明做进一步详细描述，所述是对本发明的解释而不是限5[0037]所述车辆中间数据缓存到Redis时，将车辆的起始业务状态保[0038]所述的Redis还设有定时清理历史数据的定时清理器：定时清理器按照设定的时[0039]所述的Redis还设有变量监控器，以对在写入缓存期间或运算期间产生的全局变[0042]1)iov_task_api提供面向任务的接口，其包括DefaultScheduleTask类和[0046]1)当A任务通过setnx(lockkey,currenttime+timeout)命令能成功设置lockkey6[0048]2)当A通过setnx(lockkey,currenttime+timeout)命令不能成功进入false_1,由[0051]lockvalueBnull||lockvalueAlockvalueB，判断：如果lockvalueB为……0…0…0……7[0070]采用本发明的的实时聚集，可以获取当前10分钟之前的车辆里程总数和油耗总[0073]不同业务不同的汇总频率和方式(根据业务类型而定)还有其他维度的运算也类

人人文库> 全部分类> 行业资料 > 信息产业

温馨提示

  • 1. 本站所有资源如无特殊说明，都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
  • 2. 本站的文档不包含任何第三方提供的附件图纸等，如果需要附件，请联系上传者。文件的所有权益归上传用户所有。
  • 3. 本站RAR压缩包中若带图纸，网页内容里面会有图纸预览，若没有图纸预览就没有图纸。
  • 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
  • 5. 人人文库网仅提供信息存储空间，仅对用户上传内容的表现方式做保护处理，对用户上传分享的文档内容本身不做任何修改或编辑，并不能对任何下载内容负责。
  • 6. 下载文件中如有侵权或不适当内容，请与我们联系，我们立即纠正。
  • 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。

最新文档

评论

0/150

提交评论