Home Topic library logo Library Mine
More

flink 规则引擎技术实现

出处：tech.qimao.com

摘要

当前有两类实时任务需要频繁重启：第一类任务是，实时报表新增维度，此类任务中，Flink 消费 Kafka 实时数据，处理后按照维度聚合，使用聚合函数计算出指标后写入 StarRocks ；第二类任务是实时 ETL 任务，此类任务中，Flink 消费 Kafka 实时数据，经过字段提取、数据过滤再将结果回写…

阅读原文
xiaozi 于 2024-06-08 分享
171 海报分享
关联话题： #Flink

欢迎在评论区写下你对这篇文章的看法。

评论

Home - Wiki
Copyright © 2011-2024 iteam. Current version is 2.129.0. UTC+08:00, 2024-07-04 15:36
浙ICP备14020137号-1 $Map of visitor$