第155任务：2022版Flink1.13实战教程 -拜师教育 - 师徒制教育平台|人工智能培训|大数据培训|JAVA培训|PYTHON培训|

第1任务：上阶段考核通过卡点

第2任务：文档资料下载

第3任务： 001 - 001_Flink课程简介.mp4

第4任务： 002 - 002_第一章_Flink简介（一）_Flink起源和设计理念.mp4

第5任务： 003 - 003_第一章_Flink简介（二）_Flink在企业的应用.mp4

第6任务： 004 - 004_第一章_Flink简介（三）_Flink的优势.mp4

第7任务： 005 - 005_第一章_Flink简介（四）_数据处理框架的演变.mp4

第8任务： 006 - 006_第一章_Flink简介（五）_流处理的应用场景.mp4

第9任务： 007 - 007_第一章_Flink简介（六）_Flink的分层API.mp4

第10任务： 008 - 008_第一章_Flink简介（七）_Flink和Spark的区别.mp4

第11任务： 009 - 009_第二章_Flink快速上手（一）_环境准备和创建项目.mp4

第12任务： 010 - 010_第二章_Flink快速上手（二）_批处理_Word Count（一）.mp4

第13任务： 011 - 011_第二章_Flink快速上手（二）_批处理_Word Count（二）.mp4

第14任务： 012 - 012_第二章_Flink快速上手（三）_流处理（一）_有界流处理Word Count（一）.mp4

第15任务： 013 - 013_第二章_Flink快速上手（三）_流处理（一）_有界流处理Word Count（二）.mp4

第16任务： 014 - 014_第二章_Flink快速上手（三）_流处理（二）无界流处理Word Count.mp4

第17任务：每日作业

第18任务： 015 - 015_第三章_Flink部署（一）_快速启动一个集群（一）_环境配置和基本介绍.mp4

第19任务： 016 - 016_第三章_Flink部署（一）_快速启动一个集群（二）_集群启动.mp4

第20任务： 017 - 017_第三章_Flink部署（一）_快速启动一个集群（三）_提交作业（一）_Web UI提交.mp4

第21任务： 018 - 018_第三章_Flink部署（一）_快速启动一个集群（三）_提交作业（二）_命令行提交.mp4

第22任务： 019 - 019_第三章_Flink部署（二）_部署模式.mp4

第23任务： 020 - 020_第三章_Flink部署（三）_独立模式的部署.mp4

第24任务： 021 - 021_第三章_Flink部署（四）_Yarn模式的部署.mp4

第25任务： 022 - 022_第四章_Flink运行时架构（一）_Flink系统架构.mp4

第26任务： 023 - 023_第四章_Flink运行时架构（二）_作业提交流程.mp4

第27任务： 024 - 024_第四章_Flink运行时架构（三）_一些重要概念（一）_数据流图.mp4

第28任务： 025 - 025_第四章_Flink运行时架构（三）_一些重要概念（二）_并行度.mp4

第29任务： 026 - 026_第四章_Flink运行时架构（三）_一些重要概念（三）_算子链.mp4

第30任务： 027 - 027_第四章_Flink运行时架构（三）_一些重要概念（四）_执行图.mp4

第31任务： 028 - 028_第四章_Flink运行时架构（三）_一些重要概念（五）_Task Slots.mp4

第32任务： 029 - 029_第四章_Flink运行时架构（四）_Flink的任务调度.mp4

第33任务：每日作业

第34任务： 030 - 030_第五章_DataStream API（基础篇）（一）_整体介绍.mp4

第35任务： 031 - 031_第五章_DataStream API（基础篇）（二）_执行环境.mp4

第36任务： 032 - 032_第五章_DataStream API（基础篇）（三）_源算子（一）_整体介绍.mp4

第37任务： 033 - 033_第五章_DataStream API（基础篇）（三）_源算子（二）_准备工作.mp4

第38任务： 034 - 034_第五章_DataStream API（基础篇）（三）_源算子（三）_读取有界流.mp4

第39任务： 035 - 035_第五章_DataStream API（基础篇）（三）_源算子（四）_读取Socket文本流.mp4

第40任务： 036 - 036_第五章_DataStream API（基础篇）（三）_源算子（五）_读取Kafka.mp4

第41任务： 037 - 037_第五章_DataStream API（基础篇）（三）_源算子（六）_自定义Source.mp4

第42任务： 038 - 038_第五章_DataStream API（基础篇）（三）_源算子（七）_自定义并行Source.mp4

第43任务： 039 - 039_第五章_DataStream API（基础篇）（三）_源算子（八）_Flink支持的数据类型（一）.mp4

第44任务： 040 - 040_第五章_DataStream API（基础篇）（三）_源算子（八）_Flink支持的数据类型（二）.mp4

第45任务： 041 - 041_第五章_DataStream API（基础篇）（四）_Transform（一）_Map.mp4

第46任务： 042 - 042_第五章_DataStream API（基础篇）（四）_Transform（二）_Filter.mp4

第47任务：每日作业

第48任务： 043 - 043_第五章_DataStream API（基础篇）（四）_Transform（三）_FlatMap.mp4

第49任务： 044 - 044_第五章_DataStream API（基础篇）（四）_Transform（五）_KeyBy.mp4

第50任务： 045 - 045_第五章_DataStream API（基础篇）（四）_Transform（六）_简单聚合.mp4

第51任务： 046 - 046_第五章_DataStream API（基础篇）（四）_Transform（七）_归约聚合.mp4

第52任务： 047 - 047_第五章_DataStream API（基础篇）（四）_Transform（八）_UDF（一）_函数类和匿名函数.mp4

第53任务： 048 - 048_第五章_DataStream API（基础篇）（四）_Transform（八）_UDF（二）_富函数类.mp4

第54任务： 049 - 049_第五章_DataStream API（基础篇）（四）_Transform（九）_物理分区（一）_随机和轮询分区.mp4

第55任务： 050 - 050_第五章_DataStream API（基础篇）（四）_Transform（十）_物理分区（二）_Rescale.mp4

第56任务： 051 - 051_第五章_DataStream API（基础篇）（四）_Transform（十）_物理分区（三）_广播、全局及自定义

第57任务： 052 - 052_第五章_DataStream API（基础篇）（五）_Sink（一）_连接到外部系统.mp4

第58任务： 053 - 053_第五章_DataStream API（基础篇）（五）_Sink（二）_输出到文件.mp4

第59任务： 054 - 054_第五章_DataStream API（基础篇）（五）_Sink（三）_输出到Kafka.mp4

第60任务： 055 - 055_第五章_DataStream API（基础篇）（五）_Sink（四）_输出到Redis.mp4

第61任务： 056 - 056_第五章_DataStream API（基础篇）（五）_Sink（五）_输出到Elasticsearch.mp4

第62任务： 057 - 057_第五章_DataStream API（基础篇）（五）_Sink（六）_输出到MySQL.mp4

第63任务： 058 - 058_第五章_DataStream API（基础篇）（五）_Sink（七）_自定义Sink输出.mp4

第64任务：每日作业

第65任务： 059 - 059_第六章_Flink中的时间和窗口（一）_时间语义.mp4

第66任务： 060 - 060_第六章_Flink中的时间和窗口（二）_水位线（一）_水位线的概念.mp4

第67任务： 061 - 061_第六章_Flink中的时间和窗口（二）_水位线（二）_水位线的原理和特性.mp4

第68任务： 062 - 062_第六章_Flink中的时间和窗口（二）_水位线（三）_水位线在代码中的生成（一）.mp4

第69任务： 063 - 063_第六章_Flink中的时间和窗口（二）_水位线（三）_水位线在代码中的生成（二）.mp4

第70任务： 064 - 064_第六章_Flink中的时间和窗口（二）_水位线（四）_自定义水位线的生成.mp4

第71任务： 065 - 065_第六章_Flink中的时间和窗口（二）_水位线（五）_水位线的传递.mp4

第72任务： 066 - 066_第六章_Flink中的时间和窗口（三）_窗口（一）_窗口的基本概念.mp4

第73任务： 067 - 067_第六章_Flink中的时间和窗口（三）_窗口（二）_窗口的分类.mp4

第74任务： 068 - 068_第六章_Flink中的时间和窗口（三）_窗口（三）_窗口API概览.mp4

第75任务： 069 - 069_第六章_Flink中的时间和窗口（三）_窗口（四）_窗口分配器.mp4

第76任务：每日作业

第77任务： 070 - 070_第六章_Flink中的时间和窗口（三）_窗口（五）_窗口函数整体介绍.mp4

第78任务： 071 - 071_第六章_Flink中的时间和窗口（三）_窗口（六）_窗口函数分类.mp4

第79任务： 072 - 072_第六章_Flink中的时间和窗口（三）_窗口（七）_增量聚合函数（一）_ReduceFunction.mp4

第80任务： 073 - 073_第六章_Flink中的时间和窗口（三）_窗口（七）_增量聚合函数（二）_AggregateFunction.mp4

第81任务： 074 - 074_第六章_Flink中的时间和窗口（三）_窗口（七）_增量聚合函数（三）_应用实例.mp4

第82任务： 075 - 075_第六章_Flink中的时间和窗口（三）_窗口（八）_全窗口函数.mp4

第83任务： 076 - 076_第六章_Flink中的时间和窗口（三）_窗口（九）_两种窗口函数结合.mp4

第84任务： 077 - 077_第六章_Flink中的时间和窗口（三）_窗口（十）_窗口函数综合应用实例.mp4

第85任务： 078 - 078_第六章_Flink中的时间和窗口（三）_窗口（十一）_窗口其它API.mp4

第86任务： 079 - 079_第六章_Flink中的时间和窗口（四）_处理迟到数据（一）_代码实现.mp4

第87任务： 080 - 080_第六章_Flink中的时间和窗口（四）_处理迟到数据（二）_测试.mp4

第88任务：每日作业

第89任务： 081 - 081_第七章_处理函数（一）_处理函数的概念和分类.mp4

第90任务： 082 - 082_第七章_处理函数（二）_ProcessFunction.mp4

第91任务： 083 - 083_第七章_处理函数（三）_KeyedProcessFunction（一）_处理时间定时器.mp4

第92任务： 084 - 084_第七章_处理函数（三）_KeyedProcessFunction（二）_事件时间定时器.mp4

第93任务： 085 - 085_第七章_处理函数（四）_ProcessWindowFunction.mp4

第94任务： 086 - 086_第七章_处理函数（五）_Top N（一）_使用ProcessAllWindowFunction（一）_基本思路.mp4

第95任务： 087 - 087_第七章_处理函数（五）_Top N（一）_使用ProcessAllWindowFunction（二）_代码实现和测试.mp4

第96任务： 088 - 088_第七章_处理函数（五）_Top N（二）_使用KeyedProcessFunction.mp4

第97任务：每日作业

第98任务： 089 - 089_第八章_多流转换（一）_分流.mp4

第99任务： 090 - 090_第八章_多流转换（二）_合流（一）_ 联合（Union）.mp4

第100任务： 091 - 091_第八章_多流转换（二）_合流（二）_ 连接（Connect）.mp4

第101任务： 092 - 092_第八章_多流转换（二）_合流（三）_ 应用实例（一）_程序架构和实现思路.mp4

第102任务： 093 - 093_第八章_多流转换（二）_合流（三）_ 应用实例（二）_具体代码实现.mp4

第103任务： 094 - 094_第八章_多流转换（二）_合流（四）_ 广播连接流.mp4

第104任务： 095 - 095_第八章_多流转换（三）_双流Join（一）_ 窗口联结.mp4

第105任务： 096 - 096_第八章_多流转换（三）_双流Join（二）_ 间隔联结.mp4

第106任务： 097 - 097_第八章_多流转换（三）_双流Join（三）_ 窗口同组联结.mp4

第107任务：每日作业

第108任务： 098 - 098_第九章_状态编程（一）_Flink中的状态（一）_ 状态的定义.mp4

第109任务： 099 - 099_第九章_状态编程（一）_Flink中的状态（二）_ 状态的管理.mp4

第110任务： 100 - 100_第九章_状态编程（一）_Flink中的状态（三）_ 状态的分类.mp4

第111任务： 101 - 101_第九章_状态编程（二）_按键分区状态（一）_ 基本概念和类型.mp4

第112任务： 102 - 102_第九章_状态编程（二）_按键分区状态（二）_ 代码中的使用（一）_基本方式和值状态.mp4

第113任务： 103 - 103_第九章_状态编程（二）_按键分区状态（二）_ 代码中的使用（二）_其它状态.mp4

第114任务： 104 - 104_第九章_状态编程（二）_按键分区状态（三）_ 应用实例（一）_值状态.mp4

第115任务：每日作业

第116任务： 105 - 105_第九章_状态编程（二）_按键分区状态（三）_ 应用实例（二）_列表状态.mp4

第117任务： 106 - 106_第九章_状态编程（二）_按键分区状态（三）_ 应用实例（三）_映射状态.mp4

第118任务： 107 - 107_第九章_状态编程（二）_按键分区状态（三）_ 应用实例（四）_聚合状态.mp4

第119任务： 108 - 108_第九章_状态编程（二）_按键分区状态（四）_ 状态生存时间.mp4

第120任务： 109 - 109_第九章_状态编程（三）_算子状态（一）_ 基本概念和类型.mp4

第121任务： 110 - 110_第九章_状态编程（三）_算子状态（二）_应用实例（一）_基本思路和框架.mp4

第122任务： 111 - 111_第九章_状态编程（三）_算子状态（二）_应用实例（二）_具体实现和测试.mp4

第123任务：每日作业

第124任务： 112 - 112_第九章_状态编程（四）_广播状态（一）_基本概念和用法.mp4

第125任务： 113 - 113_第九章_状态编程（四）_广播状态（二）_应用实例.mp4

第126任务： 114 - 114_第九章_状态编程（五）_状态持久化（一）_检查点.mp4

第127任务： 115 - 115_第九章_状态编程（五）_状态持久化（二）_状态后端.mp4

第128任务： 116 - 116_第十章_容错机制（一）_检查点（一）_检查点的保存原理（一）_周期性的保存.mp4

第129任务： 117 - 117_第十章_容错机制（一）_检查点（一）_检查点的保存原理（二）_保存的时间点.mp4

第130任务： 118 - 118_第十章_容错机制（一）_检查点（二）_从检查点恢复状态.mp4

第131任务： 119 - 119_第十章_容错机制（一）_检查点（三）_检查点算法（一）_分界线.mp4

第132任务： 120 - 120_第十章_容错机制（一）_检查点（三）_检查点算法（二）_分布式快照算法.mp4

第133任务： 121 - 121_第十章_容错机制（一）_检查点（四）_检查点配置.mp4

第134任务： 122 - 122_第十章_容错机制（一）_检查点（五）_保存点.mp4

第135任务：每日作业

第136任务： 123 - 123_第十章_容错机制（二）_状态一致性（一）_一致性的概念和级别.mp4

第137任务： 124 - 124_第十章_容错机制（二）_状态一致性（二）_端到端状态一致性（一）.mp4

第138任务： 125 - 125_第十章_容错机制（二）_状态一致性（二）_端到端状态一致性（二）.mp4

第139任务： 126 - 126_第十章_容错机制（二）_状态一致性（三）_端到端精确一次.mp4

第140任务： 127 - 127_第十一章_Table API和SQL（一）_整体介绍.mp4

第141任务： 128 - 128_第十一章_Table API和SQL（二）_快速上手.mp4

第142任务： 129 - 129_第十一章_Table API和SQL（三）_基本API（一）_程序架构.mp4

第143任务： 130 - 130_第十一章_Table API和SQL（三）_基本API（二）_表环境.mp4

第144任务：每日作业

第145任务： 131 - 131_第十一章_Table API和SQL（三）_基本API（三）_创建表.mp4

第146任务： 132 - 132_第十一章_Table API和SQL（三）_基本API（四）_表的查询和输出（一）.mp4

第147任务： 133 - 133_第十一章_Table API和SQL（三）_基本API（四）_表的查询和输出（二）.mp4

第148任务： 134 - 134_第十一章_Table API和SQL（三）_基本API（五）_表和流的转换（一）_表转换成流.mp4

第149任务： 135 - 135_第十一章_Table API和SQL（三）_基本API（五）_表和流的转换（二）_流转换成表.mp4

第150任务： 136 - 136_第十一章_Table API和SQL（四）_流处理中的表（一）_动态表和持续查询.mp4

第151任务： 137 - 137_第十一章_Table API和SQL（四）_流处理中的表（二）_流转换成动态表做动态查询.mp4

第152任务： 138 - 138_第十一章_Table API和SQL（四）_流处理中的表（三）_动态表编码成数据流.mp4

第153任务： 139 - 139_第十一章_Table API和SQL（五）_时间属性和窗口（一）_时间属性（一）_在DDL中定义.mp4

第154任务：每日作业

第155任务： 140 - 140_第十一章_Table API和SQL（五）_时间属性和窗口（一）_时间属性（二）_流转换成表时定义.mp

第156任务： 141 - 141_第十一章_Table API和SQL（五）_时间属性和窗口（二）_窗口.mp4

第157任务： 142 - 142_第十一章_Table API和SQL（六）_聚合查询（一）_分组聚合.mp4

第158任务： 143 - 143_第十一章_Table API和SQL（六）_聚合查询（二）_窗口聚合.mp4

第159任务： 144 - 144_第十一章_Table API和SQL（六）_聚合查询（三）_开窗聚合.mp4

第160任务： 145 - 145_第十一章_Table API和SQL（六）_聚合查询（四）_TopN（一）_普通TopN.mp4

第161任务： 146 - 146_第十一章_Table API和SQL（六）_聚合查询（四）_TopN（二）_窗口TopN.mp4

第162任务： 147 - 147_第十一章_Table API和SQL（七）_联结查询.mp4

第163任务：每日作业

第164任务： 148 - 148_第十一章_Table API和SQL（八）_函数（一）_系统函数.mp4

第165任务： 149 - 149_第十一章_Table API和SQL（八）_函数（二）_UDF（一）_整体介绍和分类.mp4

第166任务： 150 - 150_第十一章_Table API和SQL（八）_函数（二）_UDF（二）_标量函数.mp4

第167任务： 151 - 151_第十一章_Table API和SQL（八）_函数（二）_UDF（三）_表函数.mp4

第168任务： 152 - 152_第十一章_Table API和SQL（八）_函数（二）_UDF（四）_聚合函数.mp4

第169任务： 153 - 153_第十一章_Table API和SQL（八）_函数（二）_UDF（五）_表聚合函数.mp4

第170任务： 154 - 154_第十一章_Table API和SQL（九）_SQL客户端.mp4

第171任务： 155 - 155_第十一章_Table API和SQL（十）_连接到外部系统（一）_常见的外部存储.mp4

第172任务： 156 - 156_第十一章_Table API和SQL（十）_连接到外部系统（二）_Hive.mp4

第173任务：每日作业

第174任务： 157 - 157_第十二章_Flink CEP（一）_基本概念和应用.mp4

第175任务： 158 - 158_第十二章_Flink CEP（二）_快速上手（一）_需求分析和定义模式.mp4

第176任务： 159 - 159_第十二章_Flink CEP（二）_快速上手（二）_检测处理代码实现和测试.mp4

第177任务： 160 - 160_第十二章_Flink CEP（三）_模式API（一）_个体模式（一）_量词.mp4

第178任务： 161 - 161_第十二章_Flink CEP（三）_模式API（一）_个体模式（二）_条件.mp4

第179任务： 162 - 162_第十二章_Flink CEP（三）_模式API（二）_组合模式.mp4

第180任务： 163 - 163_第十二章_Flink CEP（三）_模式API（三）_模式组.mp4

第181任务： 164 - 164_第十二章_Flink CEP（三）_模式API（四）_匹配后跳过策略.mp4

第182任务： 165 - 165_第十二章_Flink CEP（四）_模式的检测处理（一）_处理匹配事件.mp4

第183任务： 166 - 166_第十二章_Flink CEP（四）_模式的检测处理（二）_处理超时事件（一）_需求分析和准备工作

第184任务： 167 - 167_第十二章_Flink CEP（四）_模式的检测处理（二）_处理超时事件（二）_代码实现和测试.mp4

第185任务： 168 - 168_第十二章_Flink CEP（四）_模式的检测处理（三）_处理迟到数据.mp4

第186任务： 169 - 169_第十二章_Flink CEP（五）_CEP状态机实现（一）_思路分析和程序框架.mp4

第187任务： 170 - 170_第十二章_Flink CEP（五）_CEP状态机实现（二）_定义状态机.mp4

第188任务： 171 - 171_第十二章_Flink CEP（五）_CEP状态机实现（三）_实现处理逻辑及测试.mp4

第189任务：每日作业

2022版Flink1.13实战教程

第155任务： 140 - 140_第十一章_Table API和SQL（五）_时间属性和窗口（一）_时间属性（二）_流转换成表时定义.mp

任务列表