“Flink实时数据处理”的版本间的差异
来自CloudWiki
Xiaolongyang(讨论 | 贡献) (→配置开发环境:intellij & IDEA && Maven &&JDK) |
Xiaolongyang(讨论 | 贡献) (→配置开发环境:intellij & IDEA && Maven &&JDK) |
||
第14行: | 第14行: | ||
=配置开发环境:intellij & IDEA && Maven &&JDK= | =配置开发环境:intellij & IDEA && Maven &&JDK= | ||
− | 1.pom.xml配置,打开IDEA<我这里使用的是2018.3.6版本> | + | '''1.pom.xml配置''',打开IDEA<我这里使用的是2018.3.6版本> |
− | (1) | + | (1)首先创建一个新项目Create New Project,操作如下 |
[[文件:newproject1.png]] | [[文件:newproject1.png]] | ||
+ | |||
+ | [[文件:newproject2.png]] | ||
+ | |||
+ | [[文件:newproject3.png]] | ||
+ | |||
+ | [[文件:newproject4.png]] |
2020年8月2日 (日) 09:46的版本
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,操作如下