-
公开(公告)号:CN117807241A
公开(公告)日:2024-04-02
申请号:CN202311669055.7
申请日:2023-12-06
Applicant: 万达信息股份有限公司
IPC: G06F16/36 , G06F40/151 , G06F16/2455
Abstract: 本发明的技术方案是公开了一种基于图结构文本和抽象工厂的flink实时任务计算方法。本发明通过对图结构文本解析和抽象工厂转化为flink算子图,构建基于图结构的flink读写和计算的任务并执行运算。在参考实时任务的规则,设计实时任务的图结构文本,通过抽象工厂将图结构解析为flink算子图,基于工厂定义的算子交互流程例如广度优先算法遍历flink算子图,从而用低代码、易扩展的方式构建flink实时应用,以此降低构建应用成本和人员培训等成本。