1 .一种基于单机的大规模图数据处理系统,其特征在于,包括数据加载模块、数据计算
模块、数据释放模块、存储管理模块和磁盘;所述磁盘存储有由若干子图构成的大规模图数
据;所述存储管理模块存储有与每一所述子图对应的状态信息;初始状态下,所述子图的状
态为活跃;
所述数据加载模块用于从所述磁盘获取状态为活跃的所述子图,并将所述子图传输至
所述数据计算模块;
所述数据计算模块用于对所述子图进行更新,并将更新产生的消息传输至所述存储管
理模块;
当更新后的所述子图存在改变时,所述数据计算模块还用于将所述子图传输至所述数
据释放模块;
当所述子图非当前轮更新中的最后一个时,所述数据释放模块用于将所述子图写入所
述磁盘;
当所述子图被写入所述磁盘时,所述存储管理模块用于将所述子图的状态设置为收
敛。
2 .根据权利要求1所述的系统,其特征在于,当更新后的所述子图不存在改变时,所述
数据计算模块还用于将所述子图写入所述磁盘。
3 .根据权利要求1所述的系统,其特征在于,当所述子图为当前轮更新中的最后一个
时,所述数据释放模块还用于将所述子图传输至所述数据加载模块。
4 .根据权利要求1所述的系统,其特征在于,当当前轮更新结束时,所述存储管理模块
还用于将接收到消息的所述子图的状态设置为活跃。
5 .根据权利要求1所述的系统,其特征在于,当当前轮更新结束且所述存储管理模块中
不存在消息缓存时,所述数据计算模块还用于对全部所述子图进行聚合,得到更新后的大
规模图数据。
6 .根据权利要求1所述的系统,其特征在于,所述存储管理模块包括消息存储单元和状
态管理单元;所述状态管理单元存储有所述状态信息;
所述数据计算模块用于将更新产生的消息传输至所述消息存储单元;
当当前轮更新结束时,所述状态管理单元用于将接收到消息的所述子图的状态设置为
活跃。
7 .根据权利要求6所述的系统,其特征在于,所述数据计算模块包括聚合计算单元;
当当前轮更新结束且所述消息存储单元内不存在消息缓存时,所述聚合计算单元用于
对全部所述子图进行聚合,得到更新后的大规模图数据。
8.根据权利要求1所述的系统,其特征在于,当所述子图被所述数据加载模块获取时,
所述存储管理模块还用于将所述子图的状态设置为等待计算。
9 .根据权利要求1所述的系统,其特征在于,当所述子图被传输至所述数据计算模块
时,所述存储管理模块还用于将所述子图的状态设置为正在计算。
10.根据权利要求1所述的系统,其特征在于,当所述子图被传输至所述数据释放模块
时,所述存储管理模块还用于将所述子图的状态设置为释放中。
权 利 要 求 书
1/1 页
2
评论