Flink实时数据处理

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

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

(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>

取自“http://www.openbrains.net/mediawiki/index.php?title=Flink实时数据处理&oldid=19909”