流计算方法、装置、设备及存储介质
公开
摘要
本发明涉及大数据领域,公开了一种流计算方法、装置、设备及存储介质。所述方法包括:从消息中间件获取数据源;基于计算需求信息生成流计算作业并提交至计算集群;调用计算集群,并基于流计算作业中的数据需求信息,从数据源中获取流计算作业对应的流数据资源;调用窗口分配器将流数据资源封装于至少一个数据窗口中;为每个数据窗口注册定时触发器和计数触发器,并对其进行监听,当任意一个数据窗口的一个触发器被激活时,则清除另一未激活的触发器,并调用窗口函数对每个数据窗口进行计算,得到流计算结果。本发明将定时与计数结合的计算触发方式以进行流计算,从而避免计算延迟或单次计算量过大的问题以提高系统稳定性。
基本信息
专利标题 :
流计算方法、装置、设备及存储介质
专利标题(英):
暂无
公开(公告)号 :
CN114610765A
申请号 :
CN202210246478.7
公开(公告)日 :
2022-06-10
申请日 :
2022-03-14
授权号 :
暂无
授权日 :
暂无
发明人 :
邹定斌
申请人 :
平安国际智慧城市科技股份有限公司
申请人地址 :
广东省深圳市前海深港合作区妈湾兴海大道3048号前海自贸大厦1-34层
代理机构 :
北京市京大律师事务所
代理人 :
苏福念
优先权 :
CN202210246478.7
主分类号 :
G06F16/2455
IPC分类号 :
G06F16/2455 G06F16/27 G06F16/28
IPC结构图谱
G
G部——物理
G06
计算;推算或计数
G06F
电数字数据处理
G06F16/2455
••••查询执行
法律状态
2022-06-10 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载