(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210666864.1 (22)申请日 2022.06.13 (71)申请人 浙江省标准 化研究院 （金砖国家标 准化 （浙江） 研究中心、 浙江省物品 编码中心） 地址 310005 浙江省杭州市环城北路3 05号 耀江发展中心5层 (72)发明人 张潞璐　朱明　陈旭文　徐珺　 黄健民　卢强　汪佳磊　关玉婷　 王国森　 (74)专利代理 机构 杭州运酬专利代理事务所 (特殊普通 合伙) 33429 专利代理师 王叶娟 (51)Int.Cl. G06F 11/30(2006.01)G06F 11/32(2006.01) G06F 9/50(2006.01) (54)发明名称 一种基于Flink分析时时大屏展示方法、 装 置、 存储介质 (57)摘要 本发明提供了一种基于Flink分析时时大屏 展示方法、 装置、 存储介质， 属于时时展示技术领 域。 它解决了无法区分快速筛选出用户整体行为 等问题。 本发明包括以下步骤： 步骤S1： 通过代码 埋点获得数据； 步骤S2： 将数据传入分布式埋点 日志收集程序； 步骤S3： 日志收集程序写入 kafka 消息队列； 步骤S4： Flink集群任务处理kafka消 息， 并将计算结果输出到kafka； 步骤S5： 程序监 听kafka计算结果， 并使用websocket时时推送 到 大屏展示。 本发明具有在直线检测过程中存在轮 廓分割明显、 图像物体非边界区域的清晰简洁等 优点。 权利要求书2页 说明书4页 附图2页 CN 114896123 A 2022.08.12 CN 114896123 A 1.一种基于Fl ink分析时时大屏展示方法， 其特 征在于， 包括以下步骤： 步骤S1： 通过代码埋 点获得数据； 步骤S2： 将数据传入分布式埋 点日志收集 程序； 步骤S3： 日志收集 程序写入kafka消息队列； 步骤S4： Fl ink集群任务处 理kafka消息， 并将计算结果输出到kafka； 步骤S5： 程序监听kafka计算结果， 并使用websocket时 时推送到大屏展示。 2.根据权利要求1所述的一种基于Flink分析时时大屏展示方法， 其特征在于， 所述的 步骤S4还 包括以下步骤： 步骤S4.1： Fl ink程序提交信息 至工作客户端； 步骤S4.2： 工作客户端提交消息 至工作管理器； 步骤S4.3： 工作管理器反馈消息已接收信号至 工作客户端； 步骤S4.4： 工作管理器提交任务至任务管理器； 步骤S4.5： 任务管理器通过任务跟踪器对执 行任务进行任务跟踪； 步骤S4.6： 任务管理器更新执 行任务至 工作管理器； 步骤S4.7： 工作管理器提交工作反馈 至Flink程序。 3.根据权利要求1所述的一种基于Flink分析时时大屏展示方法， 其特征在于， 所述的 工作客户端接收程序， 解析和优化 程序的执 行计划， 然后提交执 行计划到 工作管理器。 4.根据权利要求1所述的一种基于Flink分析时时大屏展示方法， 其特征在于， 所述的 工作管理器负责申请资源， 协调以及控制整个工作的执行过程， 包括： 调度任务、 处理检查 点、 容错。 5.根据权利要求1所述的一种基于Flink分析时时大屏展示方法， 其特征在于， 所述的 任务管理器运行在不同节点上的JVM进程， 负责接收并执行工作管 理器发送的运算符任务, 并且与工作管 理器通信， 用于 反馈任务状态信息， 在上述的基于Flink分析时时大屏展示方 法中， 所述的跟踪器是任务管理器资源 粒度的划分， 每个跟踪器都有自己独立的内存。 所有 跟踪器平均分配任务管理器的内存。 6.根据权利要求1所述的一种基于Flink分析时时大屏展示方法， 其特征在于， 所述的 运算符任务是在运营商的运算符子任务进行链化之后形成的， 具体Flink工作中有多少任 务管理器和运营商的并行度和链化的策略有关。 7.根据权利要求1所述的一种基于Flink分析时时大屏展示方法， 其特征在于， 所述的 运算符子任务： 因为Flink是分布式部署的， 程序中的每个算子， 在实际执行中被分隔为一 个或者多个运算符子任务， 运算符子任务的数量是该特定运算符的并行度。 数据流在算子 之间流动， 就对应到运算符子任务之 间的数据传输。 Flink 允许同一个工作中来自不同任务 管理器的运算符子任务可以共享同一个跟踪器。 每个跟踪器可以执行一个并行 的管路。 可 以将管路看作是多个运 算符子任务的组成的。 8.一种基于Flink分析时时大屏展示装置， 包括输入端、 输出端、 一个或多个处理器、 存 储器以及一个或多个程序， 其中所述一个或多个程序被存储在所述存储器中， 并且被配置 成由所述一个或多个处理器执行， 所述程序包括用于执行上述的基于Flink分析时时大屏 展示方法。 9.一种计算机可读存储介质， 存储有计算机程序， 所述计算机程序可被处理器执行以权　利　要　求　书 1/2 页 2 CN 114896123 A 2完成上述的基于Fl ink分析时时大屏展示方法。权　利　要　求　书 2/2 页 3 CN 114896123 A 3