홈 항목 library logo 글 내
자세히

flink 规则引擎技术实现

出处：tech.qimao.com

摘要

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

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

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

评论

홈 - 위키
Copyright © 2011-2024 iteam. Current version is 2.137.1. UTC+08:00, 2024-11-09 02:04
浙ICP备14020137号-1 $방문자$