查看“Flink实时数据处理”的源代码

=Flink实时统计目标:=
(1)编程读取kafka缓存数据

(2)商品实时统计:

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

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

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

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