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