“Flink实时数据处理”的版本间的差异
来自CloudWiki
Xiaolongyang（讨论 | 贡献） |
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)首先创建一个新项目Create New Project,操作如下 | (1)首先创建一个新项目Create New Project,操作如下 | ||
| 第30行： | 第30行： | ||
(3)修改pom.xml依赖(根据以下代码进行局部更改) | (3)修改pom.xml依赖(根据以下代码进行局部更改) | ||
| − | <nowiki><properties> | + | <nowiki> |
| + | <properties> | ||
| + | |||
<maven.compiler.target>1.8</maven.compiler.target> | <maven.compiler.target>1.8</maven.compiler.target> | ||
| + | |||
<maven.compiler.source>1.8</maven.compiler.source> | <maven.compiler.source>1.8</maven.compiler.source> | ||
| + | |||
</properties> | </properties> | ||
</nowiki> | </nowiki> | ||
2020年8月2日 (日) 10:01的版本
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,操作如下
(2)右下角都会出现 Maven projects need to be imported（项目需要导入依赖）<IDEA2020版本取消了导入默认依赖提示>
(3)修改pom.xml依赖(根据以下代码进行局部更改)
<properties> <maven.compiler.target>1.8</maven.compiler.target> <maven.compiler.source>1.8</maven.compiler.source> </properties>
