“Flink实时数据处理”的版本间的差异
来自CloudWiki
Xiaolongyang(讨论 | 贡献) (创建页面,内容为“=Flink实时推荐系统= ==Flink实时统计目标:== (1)编程读取kafka缓存数据 (2)商品实时统计: 1.每日销售额,每日访问流量实时统计 2…”) |
Xiaolongyang(讨论 | 贡献) |
||
第1行: | 第1行: | ||
− | + | =Flink实时统计目标:= | |
− | |||
− | |||
(1)编程读取kafka缓存数据 | (1)编程读取kafka缓存数据 | ||
2020年8月2日 (日) 09:22的版本
Flink实时统计目标:
(1)编程读取kafka缓存数据
(2)商品实时统计:
1.每日销售额,每日访问流量实时统计
2.每日每家门店总销售额实时统计
3.每日商品销量实时统计,并选出10大热销商品
(实现过程中,时间单位设置为1~2分钟)