1 .一种子图抽取方法,所述方法包括:
从指定数据源,获取当前时间周期相对于上一时间周期的增量数据;
根据所述增量数据,得到关系网络图的增量图数据,其中包括若干新增节点;
以各新增节点为根节点,对所述关系网络图执行子图抽取任务;在所述子图抽取任务
执行过程中,一旦检测到子节点数目达到预设阈值的目标节点,根据该目标节点的子节点
数目分配目标计算资源,利用所述目标计算资源执行以该目标节点为起点的子抽取任务。
2.如权利要求1所述的方法,其中,所述关系网络图包括节点和连接边,所述增量图数
据还包括新增连接边、新增节点属性信息、新增边属性信息中的一项或多项。
3 .如权利要求1所述的方法,其中,所述以各新增节点为根节点,对所述关系网络图执
行子图抽取任务,包括:
从所述各新增节点中选择满足预设条件的第一新增节点作为根节点;
根据该根节点的子节点数目分配初始计算资源,利用所述初始计算资源对所述关系网
络图执行以该根节点为起点的子图抽取任务。
4 .如权利要求3所述的方法,其中,所述子图抽取任务用于从所述关系网络图中的根节
点出发逐层抽取子节点构建子图;所述初始计算资源为与所述根节点的直接相连的子节点
数目相关数目的并发资源。
5 .如权利要求4所述的方法,其中,所述目标计算资源为与该目标节点的直接相连的子
节点数目相关数目的并发资源。
6 .如权利要求1所述的方法,其中,所述方法还包括:
调用actor方法远程提交异步请求,所述异步请求用于请求执行所述子图抽取任务或
所述子抽取任务;
接收返回的Object,根据Object获取所述子图抽取任务或所述子抽取任务的执行结
果。
7 .如权利要求1所述的方法,其中,所述子图抽取任务抽取的子图的度至少为2。
8.如权利要求1所述的方法,其中,所述子图抽取任务基于所述增量图数据和历史图数
据而执行;
所述方法还包括:
根据所述增量图数据,更新所述历史图数据。
9.如权利要求1所述的方法,其中,所述关系网络图为有向无环图。
10 .如权利要求1所述的方法,其中,所述子图抽取任务包括多轮迭代运算,所述子抽取
任务在多轮迭代运算的任一轮迭代运算中触发。
11 .一种子图抽取装置,所述装置包括:
获取单元,用于从指定数据源,获取当前时间周期相对于上一时间周期的增量数据;
时序计算单元,用于根据所述获取单元获取的增量数据,得到关系网络图的增量图数
据,其中包括若干新增节点;
子图抽取单元,用于以所述时序计算单元得到的各新增节点为根节点,对所述关系网
络图执行子图抽取任务;在所述子图抽取任务执行过程中,一旦检测到子节点数目达到预
设阈值的目标节点,根据该目标节点的子节点数目分配目标计算资源,利用所述目标计算
资源执行以该目标节点为起点的子抽取任务。
权 利 要 求 书
1/2 页
2
相关文档
评论