第21任务：2020新版Flink大数据137讲，实时流处理从入门到精通 -锐亚教育

第1任务： 001.尚硅谷_Flink-Flink简介

第2任务： 002.尚硅谷_Flink-Flink应用场景

第3任务： 003.尚硅谷_Flink-流式处理的提出

第4任务： 004.尚硅谷_Flink-流式处理的演变

第5任务： 005.尚硅谷_Flink-Flink的特点

第6任务： 006.尚硅谷_Flink-批处理wordcount

第7任务： 007.尚硅谷_Flink-流处理wordcount

第8任务： 008.尚硅谷_Flink-流处理wordcount扩展测试和说明

第9任务： 009.尚硅谷_Flink-Flink集群部署

第10任务： 010.尚硅谷_Flink-提交Job

第11任务： 011.尚硅谷_Flink-命令行提交Job

第12任务： 012.尚硅谷_Flink-其它方式集群部署

第13任务： 013.尚硅谷_Flink-运行时架构_运行时组件

第14任务： 014.尚硅谷_Flink-运行时架构_作业提交流程

第15任务： 015.尚硅谷_Flink-运行时架构_任务调度原理（一）_并行度和slot

第16任务： 016.尚硅谷_Flink-运行时架构_任务调度原理（二）_slot共享

第17任务： 017.尚硅谷_Flink-运行时架构_任务调度原理（三）_slot共享示例

第18任务： 018.尚硅谷_Flink-运行时架构_任务调度原理（四）_执行图和任务链

第19任务： 019.尚硅谷_Flink-运行时架构_任务调度原理（五）_自定义任务调度规则

第20任务： 020.尚硅谷_Flink-流处理API_Source（一）_从集合和文件读取数据

第21任务： 021.尚硅谷_Flink-流处理API_Source（二）_从Kafka读取数据

第22任务： 022.尚硅谷_Flink-流处理API_Source（三）_自定义Source

第23任务： 023.尚硅谷_Flink-流处理API_Transform（一）_简单转换算子

第24任务： 024.尚硅谷_Flink-流处理API_Transform（二）_简单分组聚合

第25任务： 025.尚硅谷_Flink-流处理API_Transform（三）_reduce聚合

第26任务： 026.尚硅谷_Flink-流处理API_Transform（四）_分流操作

第27任务： 027.尚硅谷_Flink-流处理API_Transform（五）_合流操作

第28任务： 028.尚硅谷_Flink-流处理API_Flink支持的数据类型

第29任务： 029.尚硅谷_Flink-流处理API_函数类和富函数类

第30任务： 030.尚硅谷_Flink-流处理API_Sink（一）_文件

第31任务： 031.尚硅谷_Flink-流处理API_Sink（二）_Kafka

第32任务： 032.尚硅谷_Flink-流处理API_Sink（三）_Redis

第33任务： 033.尚硅谷_Flink-流处理API_Sink（四）_ElasticSearch

第34任务： 034.尚硅谷_Flink-流处理API_Sink（五）_MySQL

第35任务： 035.尚硅谷_Flink-流处理API_Window API_窗口概念

第36任务： 036.尚硅谷_Flink-流处理API_Window API_窗口类型

第37任务： 037.尚硅谷_Flink-流处理API_Window API_窗口分配器

第38任务： 038.尚硅谷_Flink-流处理API_Window API_窗口函数及其它可选API

第39任务： 039.尚硅谷_Flink-流处理API_Window API_窗口计算测试

第40任务： 040.尚硅谷_Flink-时间语义

第41任务： 041.尚硅谷_Flink-时间语义的设置

第42任务： 042.尚硅谷_Flink-Watermark概念

第43任务： 043.尚硅谷_Flink-Watermark原理和特点

第44任务： 044.尚硅谷_Flink-Watermark传递

第45任务： 045.尚硅谷_Flink-Watermark代码中引入

第46任务： 046.尚硅谷_Flink-自定义Watermark生成机制

第47任务： 047.尚硅谷_Flink-事件时间语义下的窗口测试

第48任务： 048.尚硅谷_Flink-窗口起始点的确定

第49任务： 049.尚硅谷_Flink-状态管理（一）_状态的概念

第50任务： 050.尚硅谷_Flink-状态管理（二）_算子状态和键控状态

第51任务： 051.尚硅谷_Flink-状态管理（三）_状态在代码中的定义和使用

第52任务： 052.尚硅谷_Flink-状态编程示例（一）

第53任务： 053.尚硅谷_Flink-状态编程示例（二）

第54任务： 054.尚硅谷_Flink-ProcessFuntion_基本概念和使用

第55任务： 055.尚硅谷_Flink-ProcessFuntion_定时器应用示例

第56任务： 056.尚硅谷_Flink-ProcessFuntion_侧输出流应用示例

第57任务： 057.尚硅谷_Flink-状态后端

第58任务： 058.尚硅谷_Flink-容错机制_检查点概念和原理

第59任务： 059.尚硅谷_Flink-容错机制_检查点算法

第60任务： 060.尚硅谷_Flink-容错机制_checkpoint配置

第61任务： 061.尚硅谷_Flink-容错机制_重启策略配置

第62任务： 062.尚硅谷_Flink-保存点

第63任务： 063.尚硅谷_Flink-状态一致性_基本概念

第64任务： 064.尚硅谷_Flink-状态一致性_Flink端到端状态一致性的保证

第65任务： 065.尚硅谷_Flink-状态一致性_幂等写入和事务写入

第66任务： 066.尚硅谷_Flink-状态一致性_Flink与Kafka连接的状态一致性

第67任务： 067.尚硅谷_Flink-Table API和Flink SQL_基本概念和示例程序

第68任务： 068.尚硅谷_Flink-Table API和Flink SQL_基本程序结构

第69任务： 069.尚硅谷_Flink-Table API和Flink SQL_表执行环境

第70任务： 070.尚硅谷_Flink-Table API和Flink SQL_表的概念和从文件读取数据

第71任务： 071.尚硅谷_Flink-Table API和Flink SQL_从Kafka读取数据

第72任务： 072.尚硅谷_Flink-Table API和Flink SQL_表的查询转换

第73任务： 073.尚硅谷_Flink-Table API和Flink SQL_DataStream和表的转换

第74任务： 074.尚硅谷_Flink-Table API和Flink SQL_输出到文件

第75任务： 075.尚硅谷_Flink-Table API和Flink SQL_更新模式

第76任务： 076.尚硅谷_Flink-Table API和Flink SQL_Kafka管道测试

第77任务： 077.尚硅谷_Flink-Table API和Flink SQL_输出到ES

第78任务： 078.尚硅谷_Flink-Table API和Flink SQL_输出到MySQL

第79任务： 079.尚硅谷_Flink-Table API和Flink SQL_表转换成流

第80任务： 080.尚硅谷_Flink-Table API和Flink SQL_流处理和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_窗口（二）_分组窗口测试

第87任务： 087.尚硅谷_Flink-Table API和Flink SQL_窗口（三）_Over窗口

第88任务： 088.尚硅谷_Flink-Table API和Flink SQL_窗口（四）_Over窗口测试

第89任务： 089.尚硅谷_Flink-Table API和Flink SQL_函数（一）_系统内置函数

第90任务： 090.尚硅谷_Flink-Table API和Flink SQL_函数（二）_UDF函数_标量函

第91任务： 091.尚硅谷_Flink-Table API和Flink SQL_函数（三）_UDF函数_表函数

第92任务： 092.尚硅谷_Flink-Table API和Flink SQL_函数（四）_UDF函数_聚合函

第93任务： 093.尚硅谷_Flink-Table API和Flink SQL_函数（五）_UDF函数_表聚合

第94任务： 094.尚硅谷_Flink项目-电商用户行为分析_批处理和流处理以及项目选型

第95任务： 095.尚硅谷_Flink项目-电商用户行为分析_用户行为分析应用场景

第96任务： 096.尚硅谷_Flink项目-电商用户行为分析_模块设计和数据分析

第97任务： 097.尚硅谷_Flink项目-电商用户行为分析_模块需求分析_实时热门商品统计（一）

第98任务： 098.尚硅谷_Flink项目-电商用户行为分析_模块需求分析_实时热门商品统计（二）

第99任务： 099.尚硅谷_Flink项目-电商用户行为分析_模块需求分析_其它需求

第100任务： 100.尚硅谷_Flink项目-电商用户行为分析_项目框架搭建

第101任务： 101.尚硅谷_Flink项目-电商用户行为分析_实时热门商品统计（一）_窗口聚合

第102任务： 102.尚硅谷_Flink项目-电商用户行为分析_实时热门商品统计（二）_排序统计输出

第103任务： 103.尚硅谷_Flink项目-电商用户行为分析_实时热门商品统计（三）_从Kafka消费数据测试

第104任务： 104.尚硅谷_Flink项目-电商用户行为分析_实时热门商品统计（四）_批量消费Kafka数据测

第105任务： 105.尚硅谷_Flink项目-电商用户行为分析_实时热门商品统计（五）_Table API和SQ

第106任务： 106.尚硅谷_Flink项目-电商用户行为分析_实时热门页面流量统计（一）_开窗聚合统计

第107任务： 107.尚硅谷_Flink项目-电商用户行为分析_实时热门页面流量统计（二）_统计结果排序输出

第108任务： 108.尚硅谷_Flink项目-电商用户行为分析_实时热门页面流量统计（三）_乱序数据的处理

第109任务： 109.尚硅谷_Flink项目-电商用户行为分析_实时热门页面流量统计（四）_保证状态更新结果正确

第110任务： 110.尚硅谷_Flink项目-电商用户行为分析_PV统计（一）_基本实现

第111任务： 111.尚硅谷_Flink项目-电商用户行为分析_PV统计（二）_数据并行的优化

第112任务： 112.尚硅谷_Flink项目-电商用户行为分析_UV统计（一）_基本实现

第113任务： 113.尚硅谷_Flink项目-电商用户行为分析_UV统计（二）_布隆过滤器去重思路和程序架构

第114任务： 114.尚硅谷_Flink项目-电商用户行为分析_UV统计（三）_布隆过滤器简单实现

第115任务： 115.尚硅谷_Flink项目-电商用户行为分析_UV统计（四）_UV去重的布隆过滤器实现

第116任务： 116.尚硅谷_Flink项目-电商用户行为分析_APP市场推广统计（一）_自定义数据源

第117任务： 117.尚硅谷_Flink项目-电商用户行为分析_APP市场推广统计（二）_开窗聚合统计输出

第118任务： 118.尚硅谷_Flink项目-电商用户行为分析_广告点击量统计分析（一）_基本需求实现

第119任务： 119.尚硅谷_Flink项目-电商用户行为分析_广告点击量统计分析（二）_刷单行为过滤思路和整体

第120任务： 120.尚硅谷_Flink项目-电商用户行为分析_广告点击量统计分析（三）_刷单行为过滤代码实现

第121任务： 121.尚硅谷_Flink项目-电商用户行为分析_恶意登录检测（一）_实现思路和代码框架

第122任务： 122.尚硅谷_Flink项目-电商用户行为分析_恶意登录检测（二）_具体代码实现

第123任务： 123.尚硅谷_Flink项目-电商用户行为分析_恶意登录检测（三）_代码改进

第124任务： 124.尚硅谷_Flink项目-电商用户行为分析_恶意登录检测（四）_CEP代码实现

第125任务： 125.尚硅谷_Flink项目-电商用户行为分析_CEP简介（一）_CEP介绍及Pattern A

第126任务： 126.尚硅谷_Flink项目-电商用户行为分析_CEP简介（二）_个体模式

第127任务： 127.尚硅谷_Flink项目-电商用户行为分析_CEP简介（三）_模式序列

第128任务： 128.尚硅谷_Flink项目-电商用户行为分析_CEP简介（四）_模式的检测和事件处理

第129任务： 129.尚硅谷_Flink项目-电商用户行为分析_订单超时检测（一）_实现思路和程序架构

第130任务： 130.尚硅谷_Flink项目-电商用户行为分析_订单超时检测（二）_CEP具体代码实现

第131任务： 131.尚硅谷_Flink项目-电商用户行为分析_订单超时检测（三）_流式输入数据测试

第132任务： 132.尚硅谷_Flink项目-电商用户行为分析_订单超时检测（四）_ProcessFunctio

第133任务： 133.尚硅谷_Flink项目-电商用户行为分析_双流实时对账（一）_需求分析和整体架构

第134任务： 134.尚硅谷_Flink项目-电商用户行为分析_双流实时对账（二）_合流代码实现

第135任务： 135.尚硅谷_Flink项目-电商用户行为分析_Join API（一）_Window Join

第136任务： 136.尚硅谷_Flink项目-电商用户行为分析_Join API（二）_Interval Joi

第137任务： 137.尚硅谷_Flink项目-电商用户行为分析_双流实时对账（三）_Join代码实现

2020新版Flink大数据137讲，实时流处理从入门到精通

第21任务： 021.尚硅谷_Flink-流处理API_Source（二）_从Kafka读取数据

任务列表