课时01

01-Apache Flink概述-课程总体介绍

课时02

02-Apache Flink概述-Apache Flink介绍

课时03

03-Apache Flink概述-Apache Flink前世今生

课时04

04-Apache Flink概述-数据架构演变

课时05

05-Apache Flink概述-Flink特性及应用场景

课时06

06-Apache Flink概述-Flink与其他实时计算框架对比

课时07

07-Apache Flink概述-Flink概述总结

课时08

01-Flink快速入门-Flink开发环境准备

课时09

02-Flink快速入门-Flink入门案例开发环境准备

课时10

03-Flink快速入门-Flink Java 批数据处理代码

课时11

04-Flink快速入门-Flink Scala批数据处理代码

课时12

05-Flink快速入门-Flink Java 流数据处理代码

课时13

06-Flink快速入门-Flink Scala流数据处理代码

课时14

07-Flink快速入门-Flink 代码编写注意点总结

课时15

08-Flink快速入门-Flink DataStream Batch模式

课时16

09-Flink快速入门-Flink 快速入门总结

课时17

01-Flink架构-Flink组件栈介绍

课时18

02-Flink架构-Flink 客户端作用

课时19

03-Flink架构-Flink JobManager作用

课时20

04-Flink架构-Flink TaskManager作用

课时21

05-Flink基础环境准备-Flink基础环境介绍

课时22

06-Flink基础环境准备-Linux 虚拟机安装-01

课时23

07-Flink基础环境准备-Linux 虚拟机安装-02

课时24

08-Flink基础环境准备-Centos7各节点基础配置-01

课时25

09-Flink基础环境准备-Centos7各节点基础配置-02

课时26

10-Flink基础环境准备-Centos7各节点基础配置-03

课时27

11-Flink基础环境准备-各节点之间相互免密

课时28

12-Flink基础环境准备-安装jdk

课时29

13-Flink基础环境准备-搭建MySQL数据库

课时30

14-Flink基础环境准备-搭建Zookeeper

课时31

15-Flink基础环境准备-HDFS分布式文件系统配置

课时32

16-Flink基础环境准备-HDFS初始化及启动测试

课时33

17-Flink基础环境准备-Hive数据仓库工具搭建

课时34

18-Flink基础环境准备-Hive数据仓库工具测试

课时35

19-Flink基础环境准备-HBase分布式数据库搭建与测试

课时36

20-Flink基础环境准备-Redis搭建及测试

课时37

21-Flink基础环境准备-Kafka分布式搭建

课时38

22-Flink集群部署-Standalone集群部署

课时39

23-Flink集群部署-Standalone集群任务提交测试

课时40

24-Flink集群部署-Flink On Yarn 配置及任务测试

课时41

25-Flink集群部署-Standalone History 历史日志服务器配置-01

课时42

26-Flink集群部署-Standalone History 历史日志服务器配置-02

课时43

27-Flink集群部署-Flink On Yarn 历史日志服务器配置

课时44

28-Flink集群部署-Flink本地模式开启WebUI

课时45

29-Flink架构与集群部署总结

课时46

01-Flink任务提交与架构模型-总体介绍

课时47

02-Flink任务提交模式-Flink 任务运行时流程

课时48

03-Flink任务提交模式-Flink 任务提交三种模式

课时49

04-Flink任务提交模式-Standalone Session 模式提交任务命令及原理

课时50

05-Flink任务提交模式-Standalone Application模式提交任务命令及原理

课时51

06-Flink任务提交模式-Flink On Yarn 原理及环境准备

课时52

07-Flink任务提交模式-Yarn Session 任务提交模式

课时53

08-Flink任务提交模式-Yarn Session 任务提交流程

课时54

09-Flink任务提交模式-Yarn Per-job 任务提交模式

课时55

10-Flink任务提交模式-Yarn Per-job 任务提交流程

课时56

11-Flink任务提交模式-Yarn Application 任务提交流程

课时57

12-Flink HA - Flink基于Standalone HA 搭建

课时58

13-Flink HA - Flink基于Standalone HA 测试

课时59

14-Flink HA - Flink 基于Yarn HA 搭建及测试

课时60

15-Flink 术语 - Application&job&DataFlow

课时61

16-Flink 术语 - Subtask子任务与并行度

课时62

17-Flink 术语 - Flink Operator Chains算子链

课时63

18-Flink术语 - Flink Operator Chains 细粒度操作-01

课时64

19-Flink术语 - Flink Operator Chains 细粒度操作-02

课时65

20-Flink执行图 - Flink 任务提交对象转换关系

课时66

21-TaskSlot任务槽 - TaskSlot

课时67

22-TaskSlot任务槽 - TaskSlot共享与SSG

课时68

23-TaskSlot任务槽 - TaskSlot与并行度关系

课时69

24-TaskSlot任务槽 - SSG代码测试

课时70

25-TaskSlot任务槽 - 集群均匀分配TaskSlot

课时71

26-Flink细粒度资源调度 - 细粒度资源管理介绍

课时72

27-Flink细粒度资源调度 - 细粒度资源管理原理

课时73

28-Flink细粒度资源调度 - 细粒度资源调度代码测试-01

课时74

29-Flink细粒度资源调度 - 细粒度资源调度代码测试-02

课时75

30-Flink细粒度资源调度 - 细粒度资源管理局限性

课时76

31-Flink内存模型 - Flink总内存介绍

课时77

32-Flink内存模型 - Flink 各类内存作用及参数

课时78

33-Flink任务提交与架构模型-总结

课时79

01-Flink基于Kubernetes部署之大数据环境准备-环境介绍

课时80

02-Flink基于Kubernetes部署之大数据环境准备-准备阿里yum源

课时81

03-Flink基于Kubernetes部署之大数据环境准备-Zookeeper配置及部署

课时82

04-Flink基于Kubernetes部署之大数据环境准备-HDFS 搭建流程介绍

课时83

05-Flink基于Kubernetes部署之大数据环境准备-HDFS 配置文件

课时84

06-Flink基于Kubernetes部署之大数据环境准备-HDFS初始化及启停

课时85

01-Kubernetes介绍-应用程序传统部署时代及痛点

课时86

02-Kubernetes介绍-应用程序虚拟机部署优缺点

课时87

03-Kubernetes介绍-应用程序容器化部署优缺点

课时88

04-Kubernetes介绍-Kubernetes优势

课时89

05-Kubernetes架构-Kubernetes集群架构及组件-01

课时90

06-Kubernetes架构-Kubernetes几圈架构及组件-02

课时91

07-Kubernetes核心概念-Pod

课时92

08-Kubernetes核心概念-Label

课时93

09-Kubernetes核心概念-NameSpace&Controller

课时94

10-Kubernetes核心概念-Controller控制器之Deployment&ReplicaSet

课时95

11-Kubernetes核心概念-Controller控制器之StatefulSet&DaemonSet

课时96

12-Kubernetes核心概念-Controller控制器之Job&Cronjob

课时97

13-Kubernetes核心概念-Service

课时98

14-Kubernetes核心概念-Volume存储卷

课时99

15-Kubernetes核心概念-PersistentVolume持久化存储卷

课时100

16-Kubernetes核心概念-ConfigMap&Secret&ServiceAccount

课时101

17-Kubernetes集群搭建准备-节点划分及环境准备介绍

课时102

18-Kubernetes集群搭建准备-升级系统内核版本

课时103

19-Kubernetes集群搭建准备-配置其他网络环境

课时104

20-Kubernetes集群搭建准备-docker安装及配置

课时105

21-Kubernetes集群搭建-搭建整体流程准备

课时106

22-Kubernetes集群搭建-准备yum源及集群镜像准备

课时107

23-Kubernetes集群搭建-Kubernetes集群初始化

课时108

24-Kubernetes集群搭建-集群网络calico准备

课时109

25-Kubernetes集群搭建-Worker节点添加及验证集群

课时110

26-Kubernetes集群搭建-Worker命令配置及命令自动补全

课时111

27-Kubernetes集群搭建-Kubernetes dashboard搭建及访问

课时112

28-Kubernetes集群搭建-基于Kubernetes部署Nginx服务案例

课时113

29-Flink基于Kubernetes部署-两种部署模式介绍

课时114

30-Flink基于Kubernetes部署-Kubernetes部署模式介绍

课时115

31-Flink基于Kubernetes部署-SessionCluster非HA模式yaml文件

课时116

32-Flink基于Kubernetes部署-SessionCluster非HA模式部署及验证

课时117

33-Flink基于Kubernetes部署-SessionCluster非HA模式任务提交测试

课时118

34-Flink基于Kubernetes部署-SessionCluster HA 介绍

课时119

35-Flink基于Kubernetes部署-SessionCluster HA yaml文件

课时120

36-Flink基于Kubernetes部署-SessionCluster HA 模式部署

课时121

37-Flink基于Kubernetes部署-SessionCluster HA模式切换验证及任务测试

课时122

38-Flink基于Kubernetes部署-SessionCluster HA模式集群停止注意点

课时123

39-Flink基于Kubernetes部署-ApplicationCluster非HA模式yaml文件

课时124

40-Flink基于Kubernetes部署-ApplicationCluster非HA模式部署及任务提交验证

课时125

41-Flink基于Kubernetes部署-ApplicationCluster HA模式yaml文件

课时126

42-Flink基于Kubernetes部署-ApplicationCluster HA模式部署及任务提交验证

课时127

43-Flink基于Kubernetes部署-ApplicationCluster HA模式选主验证

课时128

44-Flink基于Native Kubernetes部署-Native Kubernetes部署介绍

课时129

45-Flink基于Native Kubernetes部署-Session Cluster启动

课时130

46-Flink基于Native Kubernetes部署-Session Cluster 任务提交

课时131

47-Flink基于Native Kubernetes部署-Session Cluster 资源申请与释放

课时132

48-Flink基于Native Kubernetes部署-Application Cluster部署介绍

课时133

49-Flink基于Native Kubernetes部署-Harbor配置安装-01

课时134

50-Flink基于Native Kubernetes部署-Harbor配置安装-02

课时135

51-Flink基于Native Kuberentes部署-Harbor访问测试

课时136

52-Flink基于Native Kubernetes部署-Harbor镜像上传下载测试

课时137

53-Flink基于Native Kubernetes部署-制作用户Flink镜像

课时138

54-Flink基于native Kubernetes部署-Application Cluster任务提交及测试

课时139

01-Kubernetes基于DockerRuntime部署-整体介绍

课时140

02-Kubernetes基于DockerRuntime部署-基础环境配置

课时141

03-Kubernetes基于DockerRuntime部署-Docker部署安装

课时142

04-Kubernetes基于DockerRuntime部署-cri-docker编译安装

课时143

05-Kubernetes基于DockerRuntime部署-Kubernetes集群配置

课时144

06-Kubernetes基于DockerRuntime部署-Kubenetes集群初始化

课时145

07-Kubernetes基于DockerRuntime部署-Kubenetes集群网络配置

课时146

08-Kubernetes基于DockerRuntime部署-Kubernetes Node节点加入及验证

课时147

09-Kubernetes基于DockerRuntime部署-Kubernetes集群其他一些配置

课时148

10-Kubernetes基于DockerRuntime部署-Flink基于Kubernetes部署启动测试

课时149

01-Flink编程模型与API-章节总体介绍

课时150

02-Flink编程模型 - FlinkAPI分层及代码编写流程

课时151

03-Flink编程模型 - Flink数据类型推断

课时152

04-Flink编程模型 - Flink序列化机制及自定义注册kryo序列化

课时153

05-Flink FileSource - Java代码实现

课时154

06-Flink FileSource - Scala 代码实现

课时155

07-Flink CollectionSource -Java 代码实现

课时156

08-Flink CollectionSource -Scala 代码实现

课时157

09-Flink KafkaSource - 只读取Value数据-Java 代码实现

课时158

10-Flink KafkaSource - 只读取Value数据-Scala代码实现

课时159

11-Flink KafkaSource - 读取KV数据 - Java代码实现

课时160

12-Flink KafkaSource - 读取KV数据 - Scala代码实现

课时161

13-Flink 自定义Source - SourceFunction接口-Java代码实现

课时162

14-Flink ParallelSourceFunction-Java代码实现

课时163

15-Flink 自定义Source - SourcFunction 接口 - Scala代码实现

课时164

16-Flink ParallelSourceFunction接口 - Scala代码实现

课时165

17-Flink Transformation - Map 算子Java和Scala代码实现

课时166

18-Flink Transformation - flatMap算子Java和Scala代码实现

课时167

19-Flink Transformation - Filter 算子Java和Scala代码实现

课时168

20-Flink Transformation - KeyBy算子Java和Scala代码实现

课时169

21-Flink Transformation - Aggregations算子Java代码实现

课时170

22-Flink Transformation - Aggregations算子Scala代码实现

课时171

23-Flink Transformation - Reduce算子Java和Scala代码实现

课时172

24-Flink Transformation - Union算子Java和Scala代码实现

课时173

25-Flink Transformation - Connect算子Java和Scala代码实现

课时174

26-Flink Transformation - Iterate算子Java代码实现

课时175

27-Flink Transformation - Iterate算子Scala代码实现

课时176

28-Flink 函数接口 - 案例 - Java代码实现

课时177

29-Flink 函数接口 - 案例 - Scala代码实现

课时178

30-Flink 富函数类 - 案例 - Java代码实现

课时179

31-Flink 富函数类 - 案例 - Scala代码实现

课时180

32-Flink Sink - FileSink Java代码实现

课时181

33-Flink Sink - File Sink Scala代码实现

课时182

34-Flink JDBC Sink at-least-once 语义 Java代码实现

课时183

35-Flink JDBC Sink at-least-once 语义 Scala代码实现

课时184

36-Flink JDBC Sink - exactly-once 语义 Java代码实现

课时185

37-Flink JDBC Sink - exactly-once 语义 Scala代码实现

课时186

38-Flink Sink - KafkaSink - 写出只有Value Java 代码实现

课时187

39-Flink Sink - KafkaSink - 写出KV数据 Java代码实现

课时188

40-Flink Sink - KafkaSink - 写出只有Value Scala代码实现

课时189

41-Flink Sink - KafkaSink - 写出KV数据 - Scala代码实现

课时190

42-Flink Sink - RedisSink - Java代码实现

课时191

43-Flink Sink - RedisSink - Scala代码实现

课时192

44-Flink Sink - 自定义Sink输出 - Java代码实现

课时193

45-Flink Sink- 自定义Sink输出 - Scala代码实现

课时194

46-Flink 分区操作 - Shuffle随机分区策略及代码实现

课时195

47-Flink 分区操作 - Rebalance 轮询分区策略及代码实现

课时196

48-Flink分区操作 - Rescale重缩放分区策略及Java代码实现

课时197

49-Flink分区操作 - Rescale重缩放分区策略Scala代码实现

课时198

50-Flink分区操作 - Broadcast广播分区策略及Java代码实现

课时199

51-Flink分区操作 - Broadcast广播分区策略Scala代码实现

课时200

52-Flink分区操作 - Global全局分区策略及代码实现

课时201

53-Flink分区操作 - Forward并行分区策略及代码实现

课时202

54-Flink分区操作 - 自定义分区策略代码实现

课时203

55-Flink SideOutput - 侧输出流原理及Java代码实现

课时204

56-Flink SideOutput - 侧输出流Scala代码实现

课时205

57-Flink ProcessFunction - ProcessFun介绍

课时206

58-Flink ProcessFun定时器案例-Java代码实现

课时207

59-Flink ProcessFun定时器案例-Scala代码实现

课时208

60-Flink异步IO机制 - 异步IO机制介绍

课时209

61-Flink异步IO机制 - 异步请求客户端Java代码实现

课时210

62-Flink异步IO机制 - 异步请求客户端Scala代码实现

课时211

63-Flink异步IO机制 - 线程池模拟异步客户端Java代码实现

课时212

64-Flink异步IO机制 - 线程池模拟异步客户端Scala代码实现

课时213

65-Flink编程模型与API-章节总结

课时214

01-Flink状态管理与容错-章节总体介绍

课时215

02-KeyedState 键控状态 - 键控状态使用方式

课时216

03-KeyedState 键控状态 - ValueState 值状态Java代码案例

课时217

04-KeyedState 键控状态 - ValueState 值状态Scala代码案例

课时218

05-KeyedState 键控状态 - ListState 列表状态Java代码案例

课时219

06-KeyedState 键控状态 - ListState 列表状态Scala代码案例

课时220

07-KeyedState 键控状态 - ReducingState 归约状态Java代码案例

课时221

08-KeyedState 键控状态 - ReducingState 归约状态Scala代码案例

课时222

09-KeyedState 键控状态 - AggregatingState Java代码案例

课时223

10-KeyedState 键控状态 - AggregatingState Scala代码案例

课时224

11-KeyedState 键控状态 - MapState 映射状态Java代码案例

课时225

12-KeyedState 键控状态 - MapState 映射状态Scala代码案例

课时226

13-KeyedState 键控状态 - 状态生存时间TTL Java代码案例

课时227

14-KeyedState 键控状态 - 状态生存时间TTL Scala代码案例

课时228

15-OperatorState 算子状态 - 算子状态使用方式及重分布策略

课时229

16-Operator 算子状态 - checkpointedFunction算子状态Java案例

课时230

17-Operator算子状态 - checkpointedFunction算子状态测试

课时231

18-Operator算子状态 - checkpointedFunction算子状态Scala案例

课时232

19-BroadcastState 广播状态 - Java代码案例

课时233

20-BroadcastState 广播状态 - Scala代码案例

课时234

21-Checkpoint 容错原理 - Checkpoint Barrier

课时235

22-Checkpoint 容错原理 - Barrier对齐和不对齐机制

课时236

23-Checkpoint 容错原理 - Checkpoint状态恢复及参数设置

课时237

24-Checkpoint 容错原理 - Checkpoint状态恢复案例代码编写

课时238

25-Checkpiont容错原理 - Checkpoint状态恢复案例测试

课时239

26-StateBackend 状态后端 - 状态后端分类及配置

课时240

27-StateBackend状态后端 - 状态后端案例演示

课时241

28-Savepint 检查点 - Savepoint原理及代码案例

课时242

29-Flink 端到端一致性语义保证

课时243

30-Flink Sink Kafka - 两阶段提交流程及原理

课时244

31-Flink 两阶段提交Java代码案例实现

课时245

32-Flink 两阶段提交Java代码案例测试

课时246

33-Flink 两阶段提交Scala代码案例实现及测试

课时247

34-Flink 任务重启策略与任务故障恢复策略

课时248

35-Flink 状态管理与容错章节总结