第42任务：尚硅谷2021最新Java版Flink（武老师清华硕士，原IBM-CDL负责人） -锐亚教育

第1任务： 001.尚硅谷_Flink理论_Flink简介（一）Flink是什么

第2任务： 002_尚硅谷大数据技术_Flink理论_Flink简介（二）为什么要用Flink

第3任务： 003.尚硅谷_Flink理论_Flink简介（三）流数据处理的行业

第4任务： 004.尚硅谷_Flink理论_Flink简介（四）流处理的发展演变

第5任务： 005.尚硅谷_Flink理论_Flink简介（五）Flink的特点

第6任务： 006.尚硅谷_Flink理论_Flink简介（六）Flink vs Spark Streamin

第7任务： 007.尚硅谷_Flink理论_简单上手（一）批处理WordCount

第8任务： 008.尚硅谷_Flink理论_简单上手（二）流处理WordCount

第9任务： 009.尚硅谷_Flink理论_简单上手（三）流式数据源测试

第10任务： 010.尚硅谷_Flink理论_Flink部署（一）Flink安装和配置

第11任务： 011.尚硅谷_Flink理论_Flink部署（二）Job的提交运行

第12任务： 012.尚硅谷_Flink理论_Flink部署（三）资源的分配和并行度测试

第13任务： 013.尚硅谷_Flink理论_Flink部署（四）命令行提交Job

第14任务： 014.尚硅谷_Flink理论_Flink部署（五）Yarn和K8s平台的Flink部署

第15任务： 015.尚硅谷_Flink理论_运行时架构（一）Flink四大组件

第16任务： 016.尚硅谷_Flink理论_运行时架构（二）作业提交流程_抽象架构

第17任务： 017.尚硅谷_Flink理论_运行时架构（三）Yarn上作业提交流程

第18任务： 018.尚硅谷_Flink理论_运行时架构（四）作业调度原理及思考问题

第19任务： 019.尚硅谷_Flink理论_运行时架构（五）Slot和任务调度

第20任务： 020.尚硅谷_Flink理论_运行时架构（六）Slot和并行度的关系

第21任务： 021.尚硅谷_Flink理论_运行时架构（七）程序结构和数据流图

第22任务： 022.尚硅谷_Flink理论_运行时架构（八）数据传输和任务链

第23任务： 023.尚硅谷_Flink理论_流处理API_创建执行环境

第24任务： 024.尚硅谷_Flink理论_流处理API_Source（一）从集合读取数据

第25任务： 025.尚硅谷_Flink理论_流处理API_Source（二）从文件读取数据

第26任务： 026.尚硅谷_Flink理论_流处理API_Source（三）从kafka读取数据

第27任务： 027.尚硅谷_Flink理论_流处理API_Source（四）自定义测试数据源

第28任务： 028.尚硅谷_Flink理论_流处理API_Transform（一）基本转换操作

第29任务： 029.尚硅谷_Flink理论_流处理API_Transform（二）滚动聚合

第30任务： 030.尚硅谷_Flink理论_流处理API_Transform（三）reduce聚合

第31任务： 031.尚硅谷_Flink理论_流处理API_Transform（四）分流

第32任务： 032.尚硅谷_Flink理论_流处理API_Transform（五）connect合流

第33任务： 033.尚硅谷_Flink理论_流处理API_Transform（六）union合流

第34任务： 034.尚硅谷_Flink理论_流处理API_Flink支持的数据类型

第35任务： 035.尚硅谷_Flink理论_流处理API_Flink中的UDF函数类

第36任务： 036.尚硅谷_Flink理论_流处理API_Flink中的数据重分区操作

第37任务： 037.尚硅谷_Flink理论_流处理API_Sink（一）_Kafka

第38任务： 038.尚硅谷_Flink理论_流处理API_Sink（二）_Redis

第39任务： 039.尚硅谷_Flink理论_流处理API_Sink（三）_Es

第40任务： 040.尚硅谷_Flink理论_流处理API_Sink（四）_JDBC

第41任务： 041.尚硅谷_Flink理论_Window API（一）_基本概念

第42任务： 042.尚硅谷_Flink理论_Window API（二）_窗口类型

第43任务： 043.尚硅谷_Flink理论_Window API（三）_窗口分配器

第44任务： 044.尚硅谷_Flink理论_Window API（四）_窗口函数（一）时间窗口u增量聚合

第45任务： 045.尚硅谷_Flink理论_Window API（五）_窗口函数（二）时间窗口全窗口聚合

第46任务： 046.尚硅谷_Flink理论_Window API（六）_窗口函数（三）计数窗口测试

第47任务： 047.尚硅谷_Flink理论_Window API（七）_其它可选API

第48任务： 048.尚硅谷_Flink理论_时间语义（一）_时间语义概念

第49任务： 049.尚硅谷_Flink理论_时间语义（二）_时间语义的应用

第50任务： 050.尚硅谷_Flink理论_时间语义（三）_事件时间语义的设置

第51任务： 051.尚硅谷_Flink理论_Watermark（四）_Watermark概念和原理

第52任务： 052.尚硅谷_Flink理论_Watermark（五）_Watermark特点和行为

第53任务： 053.尚硅谷_Flink理论_Watermark（六）_Watermark在任务间的传递

第54任务： 054.尚硅谷_Flink理论_Watermark（七）_Watermark在代码中的设置

第55任务： 055.尚硅谷_Flink理论_Watermark（八）_Watermark的设定原则

第56任务： 056.尚硅谷_Flink理论_事件时间语义下的窗口测试（一）

第57任务： 057.尚硅谷_Flink理论_窗口起始点和偏移量

第58任务： 058.尚硅谷_Flink理论_事件时间语义下的窗口测试（二）迟到数据处理

第59任务： 059.尚硅谷_Flink理论_状态管理（一）状态定义

第60任务： 060.尚硅谷_Flink理论_状态管理（二）算子状态

第61任务： 061.尚硅谷_Flink理论_状态管理（三）键控状态

第62任务： 062.尚硅谷_Flink理论_状态编程_温度跳变报警

第63任务： 063.尚硅谷_Flink理论_并行任务Watermark传递测试

第64任务： 064.尚硅谷_Flink理论_状态管理（四）状态后端

第65任务： 065.尚硅谷_Flink理论_ProcessFunction（一）整体介绍和分类

第66任务： 066.尚硅谷_Flink理论_ProcessFunction（二）KeyedProcessFun

第67任务： 067.尚硅谷_Flink理论_ProcessFunction（三）应用案例_一段时间内温度连续上

第68任务： 068.尚硅谷_Flink理论_ProcessFunction（四）应用案例_高低温分流

第69任务： 069.尚硅谷_Flink理论_容错机制（一）检查点概念

第70任务： 070.尚硅谷_Flink理论_容错机制（二）从检查点做故障恢复

第71任务： 071.尚硅谷_Flink理论_容错机制（三）检查点算法思路和Barrier

第72任务： 072.尚硅谷_Flink理论_容错机制（四）检查点具体算法

第73任务： 073.尚硅谷_Flink理论_容错机制（五）保存点

第74任务： 074.尚硅谷_Flink理论_容错机制（六）检查点和重启策略配置

第75任务： 075.尚硅谷_Flink理论_状态一致性（一）一致性概念和分类

第76任务： 076.尚硅谷_Flink理论_状态一致性（二）端到端状态一致性

第77任务： 077.尚硅谷_Flink理论_状态一致性（三）幂等写入

第78任务： 078.尚硅谷_Flink理论_状态一致性（四）事物写入_预写日志和两阶段提交

第79任务： 079.尚硅谷_Flink理论_状态一致性（五）事物写入_Flink和Kafka连接保证状态一致性

第80任务： 080.尚硅谷_Flink理论_Table API和Flink SQL（一）_基本介绍和简单示例

第81任务： 081.尚硅谷_Flink理论_Table API和Flink SQL（二）_基本程序结构

第82任务： 082.尚硅谷_Flink理论_Table API和Flink SQL（三）_表环境配置

第83任务： 083.尚硅谷_Flink理论_Table API和Flink SQL（四）_创建表_从文件读取数

第84任务： 084.尚硅谷_Flink理论_Table API和Flink SQL（五）_表的查询

第85任务： 085.尚硅谷_Flink理论_Table API和Flink SQL（六）_表的输出_输出到文件

第86任务： 086.尚硅谷_Flink理论_Table API和Flink SQL（七）_Kafka数据管道测

第87任务： 087.尚硅谷_Flink理论_Table API和Flink SQL（八）_更新模式

第88任务： 088.尚硅谷_Flink理论_Table API和Flink SQL（九）_输出到其它外部系统

第89任务： 089.尚硅谷_Flink理论_Table API和Flink SQL（十）_表和流的转换

第90任务： 090.尚硅谷_Flink理论_Table API和Flink SQL（十一）_动态表和持续查询

第91任务： 091.尚硅谷_Flink理论_Table API和Flink SQL（十二）_处理时间特性

第92任务： 092.尚硅谷_Flink理论_Table API和Flink SQL（十三）_事件时间特性

第93任务： 093.尚硅谷_Flink理论_Table API和Flink SQL（十四）_分组窗口

第94任务： 094.尚硅谷_Flink理论_Table API和Flink SQL（十五）_开窗函数

第95任务： 095.尚硅谷_Flink理论_Table API和Flink SQL（十六）_系统内置函数

第96任务： 096.尚硅谷_Flink理论_Table API和Flink SQL（十七）_标量函数

第97任务： 097.尚硅谷_Flink理论_Table API和Flink SQL（十八）_表函数

第98任务： 098.尚硅谷_Flink理论_Table API和Flink SQL（十九）_聚合函数

第99任务： 099.尚硅谷_Flink理论_Table API和Flink SQL（二十）_表聚合函数

第100任务： 001.尚硅谷_Flink项目_项目介绍（一）_批处理和流处理

第101任务： 002.尚硅谷_Flink项目_项目介绍（二）_电商用户行为分析

第102任务： 003.尚硅谷_Flink项目_项目介绍（三）_项目模块设计

第103任务： 004.尚硅谷_Flink项目_项目介绍（四）_项目模块分析和实现思路

第104任务： 005.尚硅谷_Flink项目_实时热门商品统计（一）_依赖引入和数据定义

第105任务： 006.尚硅谷_Flink项目_实时热门商品统计（二）_开窗聚合

第106任务： 007.尚硅谷_Flink项目_实时热门商品统计（三）_排序输出TopN

第107任务： 008.尚硅谷_Flink项目_实时热门商品统计（四）_切换Kafka数据源

第108任务： 009.尚硅谷_Flink项目_实时热门商品统计（五）_Kafka批量数据测试

第109任务： 010.尚硅谷_Flink项目_实时热门商品统计（六）_Flink SQL实现

第110任务： 011.尚硅谷_Flink项目_实时热门页面统计（一）_程序整体架构

第111任务： 012.尚硅谷_Flink项目_实时热门页面统计（二）_代码具体实现

第112任务： 013.尚硅谷_Flink项目_实时热门页面统计（三）_乱序数据测试

第113任务： 014.尚硅谷_Flink项目_实时热门页面统计（四）_乱序数据处理代码改进

第114任务： 015.尚硅谷_Flink项目_PV统计（一）_基本实现和测试

第115任务： 016.尚硅谷_Flink项目_PV统计（二）_并行和数据倾斜优化

第116任务： 017.尚硅谷_Flink项目_UV统计（一）_基于Set的去重

第117任务： 018.尚硅谷_Flink项目_UV统计（二）_布隆过滤器原理

第118任务： 019.尚硅谷_Flink项目_UV统计（三）_程序架构和自定义窗口触发器

第119任务： 020.尚硅谷_Flink项目_UV统计（四）_自定义布隆过滤器

第120任务： 021.尚硅谷_Flink项目_UV统计（五）_具体代码实现

第121任务： 022.尚硅谷_Flink项目_市场推广渠道统计（一）_整体架构和自定义测试数据源

第122任务： 023.尚硅谷_Flink项目_市场推广渠道统计（二）_具体代码实现

第123任务： 024.尚硅谷_Flink项目_市场推广统计（三）_不分渠道代码实现

第124任务： 025.尚硅谷_Flink项目_广告点击量统计（一）_基本代码实现

第125任务： 026.尚硅谷_Flink项目_广告点击量统计（二）_点击异常行为黑名单过滤

第126任务： 027.尚硅谷_Flink项目_恶意登录检测（一）_程序架构和实现思路

第127任务： 028.尚硅谷_Flink项目_恶意登录检测（二）_简单代码实现

第128任务： 029.尚硅谷_Flink项目_恶意登录检测（三）_代码时效性改进

第129任务： 030.尚硅谷_Flink项目_恶意登录检测（四）_CEP代码实现

第130任务： 031.尚硅谷_Flink项目_CEP简介（一）_CEP概念和Pattern API整体介绍

第131任务： 032.尚硅谷_Flink项目_CEP简介（二）_个体模式和模式序列

第132任务： 033.尚硅谷_Flink项目_CEP简介（三）_复杂事件的匹配检测

第133任务： 034.尚硅谷_Flink项目_CEP简介（四）_连续登录失败检测用循环模式优化

第134任务： 035.尚硅谷_Flink项目_订单超时检测（一）_CEP实现整体架构

第135任务： 036.尚硅谷_Flink项目_订单超时检测（二）_CEP具体实现和测试

第136任务： 037.尚硅谷_Flink项目_订单超时检测（三）_ProcessFunction实现思路和程序架

第137任务： 038.尚硅谷_Flink项目_订单超时检测（四）_ProcessFunction具体实现流程

第138任务： 039.尚硅谷_Flink项目_订单支付实时对账（一）_实现思路和程序架构

第139任务： 040.尚硅谷_Flink项目_订单支付实时对账（二）_具体代码实现

第140任务： 041.尚硅谷_Flink项目_Join操作（一）_Window Join

第141任务： 042.尚硅谷_Flink项目_Join操作（二）_Interval Join

第142任务： 043.尚硅谷_Flink项目_订单支付实时对账（三）_Join实现

尚硅谷2021最新Java版Flink（武老师清华硕士，原IBM-CDL负责人）

第42任务： 042.尚硅谷_Flink理论_Window API（二）_窗口类型

任务列表