Flink实时数据处理

来自CloudWiki
Xiaolongyang讨论 | 贡献2020年8月2日 (日) 09:24的版本
跳转至: 导航搜索

Flink实时统计目标:

1.编程读取kafka缓存数据

2.商品实时统计:

(1)每日销售额,每日访问流量实时统计

(2)每日每家门店总销售额实时统计

(3)每日商品销量实时统计,并选出10大热销商品

(实现过程中,时间单位设置为1~2分钟)