数据处理方法和装置
授权
摘要
本发明公开了一种数据处理方法和装置,涉及计算机技术领域。该方法应用于事件驱动分布式处理链中的处理节点,包括:在接收到输入事件后,对所述输入事件携带的水位信息进行存储;响应于水位推进逻辑的触发,确定当前水位推进时间窗口内所有输入事件的水位最小值;在所述水位最小值大于所述处理节点的当前水位时,根据所述水位最小值对所述处理节点的当前水位进行更新;在所述水位最小值小于或等于所述处理节点的当前水位时,保持所述处理节点的当前水位不变。通过以上步骤,实现了一种通用的水位推进机制,能够在几乎不增加处理延迟的情况下,提升事件驱动的分布式处理链中输出结果的准确性。
基本信息
专利标题 :
数据处理方法和装置
专利标题(英):
暂无
公开(公告)号 :
CN111478949A
申请号 :
CN202010219270.7
公开(公告)日 :
2020-07-31
申请日 :
2020-03-25
授权号 :
CN111478949B
授权日 :
2022-05-24
发明人 :
贺诗浩刘小齐何鑫尧张强
申请人 :
中国建设银行股份有限公司;建信金融科技有限责任公司
申请人地址 :
北京市西城区金融大街25号
代理机构 :
中原信达知识产权代理有限责任公司
代理人 :
张效荣
优先权 :
CN202010219270.7
主分类号 :
H04L29/08
IPC分类号 :
H04L29/08
法律状态
2022-05-24 :
授权
2020-08-25 :
实质审查的生效
IPC(主分类) : H04L 29/08
申请日 : 20200325
申请日 : 20200325
2020-07-31 :
公开
注:本法律状态信息仅供参考,即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载