数据配对方法、分润实时计算方法和流处理设备

基本信息

申请号 CN202011211681.8 申请日 -
公开(公告)号 CN114443609A 公开(公告)日 2022-05-06
申请公布号 CN114443609A 申请公布日 2022-05-06
分类号 G06F16/21(2019.01)I;G06F16/2457(2019.01)I;G06F16/248(2019.01)I;G06Q20/06(2012.01)I;G06Q40/04(2012.01)I 分类 计算;推算;计数;
发明人 不公告发明人 申请(专利权)人 拉卡拉支付股份有限公司
代理机构 北京智宇正信知识产权代理事务所(普通合伙) 代理人 李明卓
地址 100094北京市海淀区北清路中关村壹号D1座12层
法律状态 -

摘要

摘要 本发明实施例公开了一种数据配对方法、分润实时计算方法和流处理设备,其中所述数据配对方法包括:获取当前到达所述流处理框架的数据的数据流标识和标识码;从第二存储单元读取第一存储单元栈底数据的数据流标识和标识码,其中所述第一存储单元是用于存储待配对的已到达数据的先进先出型存储单元,所述第二存储单元用于存储所述第一存储单元栈底数据的数据流标识和标识码;判断当前到达数据与所述第一存储单元栈底数据的数据流标识是否一致;在不一致时判断所述当前到达数据与所述第一存储单元栈底数据的标识码是否一致;在一致时从所述第一存储单元取出所述栈底数据与所述当前到达数据配对。