公开(公告)号：CN105760511B

公开(公告)日：2018-11-13

申请号：CN201610100571.1

申请日：2016-02-24

Applicant: 南京信息职业技术学院

Inventor： 陆莉莉 ,  何淼 ,  季一木 ,  史海峰 ,  谈杰 ,  凌宝慧 ,  武文扬

IPC: G06F17/30

Abstract: 本发明提供了一种基于storm的大数据自适应拓扑处理方法，步骤包括：监听用户请求、请求信息解析、生成拓扑逻辑以及数据流查询。通过实时监听用户的定制服务请求来根据不同用户的不同需求选择运算算子，动态地定制服务，生成storm可识别运算的拓扑逻辑，从而达到数据处理服务的动态定制和实时处理，并采用算子执行树方便选择相应的算子，从而组成符合用户定制请求的最优算子执行拓扑，增强了数据流查询和挖掘的针对性，最大可能地保证数据的时效性。

公开(公告)号：CN105760511A

公开(公告)日：2016-07-13

申请号：CN201610100571.1

申请日：2016-02-24

Applicant: 南京信息职业技术学院

Inventor： 陆莉莉 ,  何淼 ,  季一木 ,  史海峰 ,  谈杰 ,  凌宝慧 ,  武文扬

IPC: G06F17/30

Abstract: 本发明提供了一种基于storm的大数据自适应拓扑处理方法，步骤包括：监听用户请求、请求信息解析、生成拓扑逻辑以及数据流查询。通过实时监听用户的定制服务请求来根据不同用户的不同需求选择运算算子，动态地定制服务，生成storm可识别运算的拓扑逻辑，从而达到数据处理服务的动态定制和实时处理，并采用算子执行树方便选择相应的算子，从而组成符合用户定制请求的最优算子执行拓扑，增强了数据流查询和挖掘的针对性，最大可能地保证数据的时效性。