公开(公告)号：CN117312389A

公开(公告)日：2023-12-29

申请号：CN202311334443.X

申请日：2023-10-13

Applicant: 杭州安恒信息技术股份有限公司

Inventor： 范俊翔 ,  洪晨港

IPC: G06F16/2455 ,  G06F16/2458 ,  G06F8/41

Abstract: 本申请涉及一种关联规则引擎的构建方法、装置和计算机设备。所述方法包括：确定当前的关联规则引擎；其中，当前的关联规则引擎包括已加载的第一关联规则；在检测到新增第二关联规则的情况下，将第二关联规则与第一关联规则进行比对，得到比对结果；在比对结果指示二者不同的情况下，对第二关联规则进行语法解析处理，生成对应的抽象语法树，并将抽象语法树动态编译为机器代码；基于机器代码，构建生成新的关联规则引擎。本申请解决了规则集维护更新困难的问题，并且提高了解析过程效率，提高了关联规则引擎的执行效率。

公开(公告)号：CN119576880A

公开(公告)日：2025-03-07

申请号：CN202411745601.5

申请日：2024-11-29

Applicant: 杭州安恒信息技术股份有限公司

Inventor： 范俊翔 ,  洪晨港

IPC: G06F16/174 ,  G06F16/17 ,  G06F16/25

Abstract: 本申请公开了基于Flink引擎的数据处理方法、装置、设备及介质，涉及大数据处理技术领域，包括：基于预设多语言序列化框架进行线程安全的实例创建，并将待序列化对象注册至得到的目标实例中；基于预设集成策略并将所述目标实例集成至Flink引擎中的数据传输层、状态管理组件，以得到相应的集成后计算引擎；在利用所述集成后计算引擎进行数据处理的过程中，通过预设字符串压缩算法、零拷贝序列化原则以及所述目标实例触发序列化操作和/或反序列化操作，以完成相应的引擎节点间的数据传输操作、Flink引擎的状态后端的状态存储操作。能够有效提高数据处理的效率、可靠性以及适用性。