关于一份数据多个统计指标的是如何实际来开发的?

来源:9-12 本章作业

liangqi000

2019-08-28

老师好:
就这节的实战例子,一份数据需要有多个统计指标输出,那么在实际业务场景中也是这么实现的吗?一份kafka数据可能同时需要统计多个指标,是使用不同groupid读取同一份Kafka数据,然后开发多个flink task来实现,还是说使用一个flink task 可能重复处理(不知道有没有拷贝流这么一说)来实现不同的业务指标统计?
求指教

写回答

1回答

Michael_PK

2019-08-28

一般我们是对接进来数据后,能多个业务一起处理就一起,实在不行就分开,分开处理得使用不同的group

0
2
Michael_PK
回复
liangqi000
你的思路是可以的。但是 但是 但是 比如说的1个是1分钟 一个是5分钟 这种跨度不一样的,我们是不放在一个作业里面计算的。作为实时处理,首先 时间跨度一般都不会很大的,如果大了 那就直接走离线的就行了。
2019-08-28
共2条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程