• 热门行业
  • 装修建材
  • 家居生活
  • 餐饮食品
  • 母婴教育
  • 电脑办公
  • 服装首饰
  • 汽车工具
  • 家电数码
  • 机械化工
  • 休闲美容
返回上一页
专利状态
一种基于Flink的实时计算方法及系统
有效
专利申请进度
申请
2020-03-19
申请公布
2020-07-07
授权
2023-08-18
预估到期
2040-03-19
专利基础信息
申请号 CN202010197103.7 申请日 2020-03-19
申请公布号 CN111382150A 申请公布日 2020-07-07
授权公布号 CN111382150B 授权公告日 2023-08-18
分类号 G06F16/215;G06F16/2455;G06F16/27;G06F9/54;G06Q20/40;G06Q40/04
分类 计算;推算;计数;
申请人名称 交通银行股份有限公司
申请人地址 上海市浦东新区自由贸易试验区银城中路188号
专利法律状态
  • 2023-08-18
    授权
    状态信息
    授权
  • 2020-07-31
    实质审查的生效
    状态信息
    实质审查的生效;IPC(主分类):G06F16/215;申请日:20200319
  • 2020-07-07
    公布
    状态信息
    公布
摘要
本发明涉及一种基于Flink的实时计算方法及系统,该方法包括如下步骤:(1)实时数据的获取:获取用于计算的数据源至接入层,触发实时计算;(2)实时数据的清洗和分析处理:采用实时流计算引擎Flink对获取的数据源进行实时的数据清洗和计算,聚合计算结果;(3)实时计算结果持久化:对计算结果进行持久化并完成数据分发。与现有技术相比,本发明方法及系统能够建立高吞吐量、低延迟、高性能的实时计算,满足对业务数据改变的实时地监控和响应,为实时采集客户行为、实时营销计算、实时风险监测等不同场景提供有效服务。