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

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

2.商品实时统计:

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

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

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

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

=配置开发环境:intellij & IDEA && Maven &&JDK=

'''1.pom.xml配置''',打开IDEA<我这里使用的是2018.3.6版本>

(1)首先创建一个新项目Create New Project,操作如下

[[文件:newproject1.png]]

[[文件:newproject2.png]]

[[文件:newproject3.png]]

[[文件:newproject4.png]]