第三章只需一个官网项目学会flink

桃扇骨 2024-04-03 12:39 19阅读 0赞

## 第三章 简单应用开发 ##

### 一、flink处理流程 ###

**三步走source→transform→sink**  
![在这里插入图片描述][341a49cece4a40c9975875967a7752d9.jpeg_pic_center]  
![在这里插入图片描述][a8767e0f3328498788c0496809dffe4f.jpeg_pic_center]

**代码分五步**  
1.获取一个执行环境（execution environment）；  
2.加载/创建初始数据；  
3.指定数据相关的转换；  
4.指定计算结果的存储位置；  
5.触发程序执行

### 二、项目实践 ###

实践项目请移步：[第1-3章项目实践][1-3]

### 三、Flink应用场景 ###

Flink 主要应用场景有四类：

*  ETL（抽取、转换、加载）【管道任务】  
    例如：从一个或多个数据源获取数据，进行一些转换操作和信息补充，将结果存储起来。
 *  Event Time and Watermarks【流式分析】  
    例如：在计算过去的特定一天里第一个小时股票的最高价格
 *  【事件驱动应用】  
    例如：计算每个小时内每个司机的小费总和
 *  【通过状态快照实现容错处理】

### 四、官网实践应用 ###

##### 练习内容： #####

*  过滤流(车程清理)
 *  有状态的增强(车程及车费)
 *  窗口分析(每小时小费)
 *  ProcessFunction 及定时器(长车程警报)

**官网案例项目flink-training下载地址：**  
::: tip  
完整项目介绍点击[这里][Link 1]  
:::

[341a49cece4a40c9975875967a7752d9.jpeg_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/25f89a0add314db993fc2a7a74a28863.jpeg
[a8767e0f3328498788c0496809dffe4f.jpeg_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/03/fc646cf7329841e0bb16427eb584707c.jpeg
[1-3]: http://www.681vip.com/tips-projectIntroduce/chapter1_3.html
[Link 1]: https://www.681vip.com/tips-projectIntroduce/chapter1_6.html