一种实时数据流的统计方法和装置

基本信息

申请号 CN201910573816.6 申请日 -
公开(公告)号 CN112148762A 公开(公告)日 2020-12-29
申请公布号 CN112148762A 申请公布日 2020-12-29
分类号 G06F16/2458(2019.01)I 分类 计算;推算;计数;
发明人 韩路 申请(专利权)人 西安京迅递供应链科技有限公司
代理机构 中原信达知识产权代理有限责任公司 代理人 西安京迅递供应链科技有限公司
地址 710100陕西省西安市国家民用航天产业基地东长安街666号航天城中心广场5号楼
法律状态 -

摘要

摘要 本发明公开了一种实时数据流的统计方法和装置,涉及计算机技术领域。该方法的一具体实施方式包括:根据读取的数据流,注册所述数据流的虚拟表;在所述数据流的虚拟表上加载运行预置的SQL语句文件;将运行后得到的实时统计结果进行存储。该实施方式克服了数据流计算框架基于各种API算子对多个数据流进行处理时处理过程复杂的技术问题,进而达到通过编写SQL语句就可以替换复杂的转换计算函数,来实现业务场景下对实时数据流的统计的技术效果。