Flink入门到实战

体系课

0 人浏览发布 2026-06-09更新 2026-06-09

随着Flink技术的飞速发展，Flink在实时处理数据方面体现出越来越显著的优势。Flink作为一个针对流数据和批数据的分布式处理引擎，其应用领域越来越广泛。本

* 第一章就业课（2.1）-Flink基础/

* Flink基础介绍/

* 01_学习目标

* 02_Flink介绍_Flink引入

* 03_Flink介绍_什么是Flink

* 04_Flink介绍_性能比较

* 05_Flink和阿里巴巴

* 06_Flink部署_伪集群模式安装

* 07_Flink部署_StandAlone集群模式安装

* 08_Flink部署_StandAlone集群HA模式安装

* 09_Flink部署_Yarn集群环境

* 10_Flink部署_Yarn-session介绍_会话模式

* 11_Flink部署_分离模式

* 12_Flink基石介绍

* 13_Flink组件栈

* 14_Flink编程模型

* 15_Flink程序结构

* 16_Flink并行数据流

* 17_任务调度与执行

* 18_Flink统一的流处理与批处理

* 19_Flink的应用场景

* Flink批处理开发/

* 01_学习目标

* 02_批处理环境搭建

* 03_加载本地数据源

* 04_加载文件数据源

* 05_Transformation简介

* 06_转换操作_map

* 07_转换操作_flatmap

* 08_转换操作_mapPartition

* 09_转换操作_filter

* 10_转换操作_reduce

* 11_转换操作_reduceGruop

* 12_转换操作_aggregate

* 13_转换操作_distinct

* 14_转换操作_union

* 15_转换操作_rebalance

* 16_转换操作_PartitionByHash

* 17_转换操作_sortPartition

* 18_落地操作_本地集合

* 19_落地操作_本地文件

* 20_Flink本地执行环境

* 21_Flink集群执行环境

* 22_广播变量

* 23_Flink的累加器

* 24_分布式缓存

* Flink流处理开发/

* 01_学习目标

* 02_数据源_集合

* 03_数据源_基于文件

* 04_数据源_基于网络套接字

* 05_数据源_自定义source

* 06_数据源_Kafka

* 07_数据源_MySQL

* 08_转换操作_keyBy

* 09_转换操作_Connect

* 10_转换操作_Split和select

* 11_数据落地_Kafka

* 12_数据落地_MySql

* 13_Window操作_什么是Window

* 14_Window操作_时间窗口介绍

* 15_Window操作_TumblingTimeWindow

* 16_Window操作_SlidingTimeWindow

* 17_Window操作_CountWindow

* 18_Window操作_ apply

* 19_水印机制_时间类型

* 20_水印机制_介绍

* 21_水印机制_代码实现

* 第二章就业课（2.1）-Flink 高级进阶/

* Flink高级开发/

* 01_学习目标

* 02_State介绍

* 03_Keyed State介绍

* 04_Operate State介绍

* 05_CheckPoint介绍

* 06_Barrier介绍

* 07_Checkpoint持久化方案

* 08_CheckPoint案例介绍

* 09_CheckPoint案例开发-自定义数据源

* 10_CheckPoint案例开发-自定义状态

* 11_CheckPoint案例开发-自定义Window和检查点

* 12_CheckPoint案例开发-主业务

* 13_FlinkSql_介绍

* 14_Table API和SQL程序的结构

* 15_FlinkSql_入门案例_DataStream或DataSet转换为表格

* 16_FlinkSql_入门案例_表转换为DataStream

* 17_FlinkSql_入门案例_表转换为DataSet

* 18_FlinkSql_批处理案例1

* 19_FlinkSql_批处理案例2

* 20_FlinkSql_流处理案例

* 第三章就业课（2.1）-Flink电商指标分析项目/

* 项目简介以及上报服务系统开发/

* 01_项目简介

* 02_项目流程介绍

* 03_项目的技术选型

* 04_IDEA工程搭建

* 05_SpringBoot简介

* 06_SpringBoot入门案例

* 07_Kafka-Manager安装

* 08_KafkaTemplate创建

* 09_KafkaTemplate测试

* 10_自定义分区

* 11_上报服务模块编写

* 12_消息模拟器

* Flink整合kafka开发/

* 13_实时分析系统介绍

* 14_ConfigFactory使用

* 15_初始化Flink流式环境

* 16_添加checkpoint的支持

* 17_整合Kafka

* 18_消息转换为元组

* 19_消息转换为样例类ClickLog

* 20_消息转换为样例类Message

* 21_添加水印支持

* HBaseUtil工具类开发/

* 01_HBase工具类介绍

* 02_HBaseUtil基本设置

* 03_HBaseUtil之getTable编写

* 04_HBaseUtil之putData

* 05_HBaseUtil之getData

* 06_HBaseUtil之putMapData

* 07_HBaseUtil之getMapData

* 08_HBaseUtil之deleteData

* 实时数据业务分析开发/

* 09_业务开发流程介绍

* 10_实时数据预处理_创建宽表样例类

* 11_实时数据预处理_扩宽地域时间

* 12_实时数据预处理_扩宽isNew

* 13_实时数据预处理_扩宽isHourNew_isDayNew_isMonthNew

* 14_业务分析_实时频道热点

* 15_业务分析_实时频道热点_落地HBase

* 16_业务分析_频道小时维度PVUV

* 17_业务分析_频道天月维度PVUV

* 18_业务分析_用户新鲜度

* 19_业务分析_用户新鲜度_落地HBase

* 1_业务分析_模板方法抽取BaseTask

* 2_业务分析_重构新鲜度分析

* 3_业务分析_频道地域

* 4_业务分析_频道地域落地HBase

* 5_业务分析_运营商分析

* 6_业务分析_运营商分析_落地HBase

* 7_业务分析_浏览器分析

* 实时数据同步系统开发/

* 8_实时同步系统介绍

* 9_采集方案_LogStash介绍

* 10_采集方案_Canal介绍

* 11_数据库采集系统介绍

* 12_MySql离线安装

* 13_MySql开启binlog

* 14_MySql主从复制介绍

* 15_Cananl原理介绍

* 16_Canal安装

* 17_Canal采集程序搭建【废弃待重录】

* 01_binlog说明

* 02_Flink实时同步应用开发介绍

* 03_项目初始化

* 04_Flink初始化

* 05_Flink整合Kafka

* 06_消息转换为Canal样例类

* 07_添加水印

* 08_HBaseOperation样例类

* 09_Canal转HBaseOperation介绍

* 10_PreprocessTask开发

* 11_Canal数据存储到HBase

* Flink离线分析系统开发/

* 12_离线分析系统简介

* 13_初始化Flink批处理环境

* 14_导入测试数据

* 15_整合HBase

* 16_测试读取HBase表数据_解决版本冲突

* 17_JSON转换为样例类

* 18_数据预处理_拓宽时间字段

* 19_业务分析_不同支付方式

* 20_业务分析_不同商家

* 21_项目总结

Flink入门到实战

体系课

0 人浏览发布 2026-06-09更新 2026-06-09

* 第一章就业课（2.1）-Flink基础/

* Flink基础介绍/

* 01_学习目标

* 02_Flink介绍_Flink引入

* 03_Flink介绍_什么是Flink

* 04_Flink介绍_性能比较

* 05_Flink和阿里巴巴

* 06_Flink部署_伪集群模式安装

* 07_Flink部署_StandAlone集群模式安装

* 08_Flink部署_StandAlone集群HA模式安装

* 09_Flink部署_Yarn集群环境

* 10_Flink部署_Yarn-session介绍_会话模式

* 11_Flink部署_分离模式

* 12_Flink基石介绍

* 13_Flink组件栈

* 14_Flink编程模型

* 15_Flink程序结构

* 16_Flink并行数据流

* 17_任务调度与执行

* 18_Flink统一的流处理与批处理

* 19_Flink的应用场景

* Flink批处理开发/

* 01_学习目标

* 02_批处理环境搭建

* 03_加载本地数据源

* 04_加载文件数据源

* 05_Transformation简介

* 06_转换操作_map

* 07_转换操作_flatmap

* 08_转换操作_mapPartition

* 09_转换操作_filter

* 10_转换操作_reduce

* 11_转换操作_reduceGruop

* 12_转换操作_aggregate

* 13_转换操作_distinct

* 14_转换操作_union

* 15_转换操作_rebalance

* 16_转换操作_PartitionByHash

* 17_转换操作_sortPartition

* 18_落地操作_本地集合

* 19_落地操作_本地文件

* 20_Flink本地执行环境

* 21_Flink集群执行环境

* 22_广播变量

* 23_Flink的累加器

* 24_分布式缓存

* Flink流处理开发/

* 01_学习目标

* 02_数据源_集合

* 03_数据源_基于文件

* 04_数据源_基于网络套接字

* 05_数据源_自定义source

* 06_数据源_Kafka

* 07_数据源_MySQL

* 08_转换操作_keyBy

* 09_转换操作_Connect

* 10_转换操作_Split和select

* 11_数据落地_Kafka

* 12_数据落地_MySql

* 13_Window操作_什么是Window

* 14_Window操作_时间窗口介绍

* 15_Window操作_TumblingTimeWindow

* 16_Window操作_SlidingTimeWindow

* 17_Window操作_CountWindow

* 18_Window操作_ apply

* 19_水印机制_时间类型

* 20_水印机制_介绍

* 21_水印机制_代码实现

* 第二章就业课（2.1）-Flink 高级进阶/

* Flink高级开发/

* 01_学习目标

* 02_State介绍

* 03_Keyed State介绍

* 04_Operate State介绍

* 05_CheckPoint介绍

* 06_Barrier介绍

* 07_Checkpoint持久化方案

* 08_CheckPoint案例介绍

* 09_CheckPoint案例开发-自定义数据源

* 10_CheckPoint案例开发-自定义状态

* 11_CheckPoint案例开发-自定义Window和检查点

* 12_CheckPoint案例开发-主业务

* 13_FlinkSql_介绍

* 14_Table API和SQL程序的结构

* 15_FlinkSql_入门案例_DataStream或DataSet转换为表格

* 16_FlinkSql_入门案例_表转换为DataStream

* 17_FlinkSql_入门案例_表转换为DataSet

* 18_FlinkSql_批处理案例1

* 19_FlinkSql_批处理案例2

* 20_FlinkSql_流处理案例

* 第三章就业课（2.1）-Flink电商指标分析项目/

* 项目简介以及上报服务系统开发/

* 01_项目简介

* 02_项目流程介绍

* 03_项目的技术选型

* 04_IDEA工程搭建

* 05_SpringBoot简介

* 06_SpringBoot入门案例

* 07_Kafka-Manager安装

* 08_KafkaTemplate创建

* 09_KafkaTemplate测试

* 10_自定义分区

* 11_上报服务模块编写

* 12_消息模拟器

* Flink整合kafka开发/

* 13_实时分析系统介绍

* 14_ConfigFactory使用

* 15_初始化Flink流式环境

* 16_添加checkpoint的支持

* 17_整合Kafka

* 18_消息转换为元组

* 19_消息转换为样例类ClickLog

* 20_消息转换为样例类Message

* 21_添加水印支持

* HBaseUtil工具类开发/

* 01_HBase工具类介绍

* 02_HBaseUtil基本设置

* 03_HBaseUtil之getTable编写

* 04_HBaseUtil之putData

* 05_HBaseUtil之getData

* 06_HBaseUtil之putMapData

* 07_HBaseUtil之getMapData

* 08_HBaseUtil之deleteData

* 实时数据业务分析开发/

* 09_业务开发流程介绍

* 10_实时数据预处理_创建宽表样例类

* 11_实时数据预处理_扩宽地域时间

* 12_实时数据预处理_扩宽isNew

* 13_实时数据预处理_扩宽isHourNew_isDayNew_isMonthNew

* 14_业务分析_实时频道热点

* 15_业务分析_实时频道热点_落地HBase

* 16_业务分析_频道小时维度PVUV

* 17_业务分析_频道天月维度PVUV

* 18_业务分析_用户新鲜度

* 19_业务分析_用户新鲜度_落地HBase

* 1_业务分析_模板方法抽取BaseTask

* 2_业务分析_重构新鲜度分析

* 3_业务分析_频道地域

* 4_业务分析_频道地域落地HBase

* 5_业务分析_运营商分析

* 6_业务分析_运营商分析_落地HBase

* 7_业务分析_浏览器分析

* 实时数据同步系统开发/

* 8_实时同步系统介绍

* 9_采集方案_LogStash介绍

* 10_采集方案_Canal介绍

* 11_数据库采集系统介绍

* 12_MySql离线安装

* 13_MySql开启binlog

* 14_MySql主从复制介绍

* 15_Cananl原理介绍

* 16_Canal安装

* 17_Canal采集程序搭建【废弃待重录】

* 01_binlog说明

* 02_Flink实时同步应用开发介绍

* 03_项目初始化

* 04_Flink初始化

* 05_Flink整合Kafka

* 06_消息转换为Canal样例类

* 07_添加水印

* 08_HBaseOperation样例类

* 09_Canal转HBaseOperation介绍

* 10_PreprocessTask开发

* 11_Canal数据存储到HBase

* Flink离线分析系统开发/

* 12_离线分析系统简介

* 13_初始化Flink批处理环境

* 14_导入测试数据

* 15_整合HBase

* 16_测试读取HBase表数据_解决版本冲突

* 17_JSON转换为样例类

* 18_数据预处理_拓宽时间字段

* 19_业务分析_不同支付方式

* 20_业务分析_不同商家

* 21_项目总结