版权所有:内蒙古大学图书馆 技术提供:维普资讯• 智图
内蒙古自治区呼和浩特市赛罕区大学西街235号 邮编: 010021
专利申请号:CN201710947537.2
公 开 号:CN107729147B
专利类型:授权发明
申 请 日:20210921
公 开 日:20140306
专利主分类号:G06F9/50(20060101)
关 键 词:工作节点 并发度 计算系统 处理速度信息 数据流量信息 方法和装置 控制节点 实时调整 实时数据 实时需求 数据处理 业务处理 优化
摘 要:本发明公开了一种流计算系统中的数据处理方法、控制节点及流计算系统,该方法包括:收集每个工作节点与其它工作节点之间的数据流量信息和每个工作节点的处理速度信息;根据收集到的数据流量信息和处理速度信息确定每个工作节点的优化并发度;根据工作节点的优化并发度对工作节点的并发度进行调整。本发明公开的方法和装置根据流计算系统中的实时数据对工作节点的并发度进行实时调整,使得工作节点的处理能力能够符合业务处理的实时需求。