课程介绍
课程章节
章节1:第一章 Apache Flink概述 (7节)

课时01

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

9分43秒

课时02

02-Apache Flink概述-Apache Flink介绍

14分13秒

课时03

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

20分29秒

课时04

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

14分47秒

课时05

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

12分55秒

课时06

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

8分14秒

课时07

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

10分57秒

章节2:第二章 Flink快速入门 (9节)

课时08

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

7分21秒

课时09

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

15分33秒

课时10

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

22分12秒

课时11

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

8分14秒

课时12

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

10分56秒

课时13

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

8分15秒

课时14

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

10分55秒

课时15

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

9分1秒

课时16

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

8分36秒

章节3:第三章 Flink架构与集群部署 (29节)

课时17

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

6分41秒

课时18

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

4分12秒

课时19

03-Flink架构-Flink JobManager作用

5分35秒

课时20

04-Flink架构-Flink TaskManager作用

3分55秒

课时21

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

6分13秒

课时22

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

24分0秒

课时23

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

7分4秒

课时24

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

17分7秒

课时25

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

13分25秒

课时26

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

9分51秒

课时27

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

12分37秒

课时28

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

10分4秒

课时29

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

13分9秒

课时30

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

9分57秒

课时31

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

22分29秒

课时32

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

9分0秒

课时33

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

12分52秒

课时34

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

7分44秒

课时35

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

18分55秒

课时36

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

10分12秒

课时37

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

19分31秒

课时38

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

19分56秒

课时39

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

20分22秒

课时40

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

19分36秒

课时41

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

20分18秒

课时42

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

2分28秒

课时43

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

13分13秒

课时44

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

16分53秒

课时45

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

5分40秒

章节4:第四章 Apache Flink 任务提交与架构模型 (33节)

课时46

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

3分33秒

课时47

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

10分57秒

课时48

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

15分15秒

课时49

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

14分46秒

课时50

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

11分29秒

课时51

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

17分34秒

课时52

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

26分16秒

课时53

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

3分53秒

课时54

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

11分33秒

课时55

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

3分13秒

课时56

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

8分24秒

课时57

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

17分24秒

课时58

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

12分44秒

课时59

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

18分0秒

课时60

15-Flink 术语 - Application&job&DataFlow

7分55秒

课时61

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

22分59秒

课时62

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

21分9秒

课时63

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

16分5秒

课时64

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

4分21秒

课时65

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

8分9秒

课时66

21-TaskSlot任务槽 - TaskSlot

7分51秒

课时67

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

16分25秒

课时68

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

7分27秒

课时69

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

18分2秒

课时70

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

19分36秒

课时71

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

17分58秒

课时72

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

10分59秒

课时73

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

10分5秒

课时74

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

17分48秒

课时75

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

2分22秒

课时76

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

7分8秒

课时77

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

8分30秒

课时78

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

16分16秒

章节5:第五章Flink基于Kubernetes部署之大数据环境准备 (6节)

课时79

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

3分6秒

课时80

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

2分47秒

课时81

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

6分31秒

课时82

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

5分22秒

课时83

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

12分54秒

课时84

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

6分16秒

章节6:第五-1章 Flink基于Kubernetes部署 (54节)

课时85

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

7分57秒

课时86

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

8分9秒

课时87

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

7分0秒

课时88

04-Kubernetes介绍-Kubernetes优势

15分19秒

课时89

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

8分45秒

课时90

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

6分7秒

课时91

07-Kubernetes核心概念-Pod

5分47秒

课时92

08-Kubernetes核心概念-Label

6分57秒

课时93

09-Kubernetes核心概念-NameSpace&Controller

5分2秒

课时94

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

9分36秒

课时95

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

5分16秒

课时96

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

3分43秒

课时97

13-Kubernetes核心概念-Service

9分10秒

课时98

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

9分49秒

课时99

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

4分9秒

课时100

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

4分38秒

课时101

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

4分25秒

课时102

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

6分13秒

课时103

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

4分23秒

课时104

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

12分9秒

课时105

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

6分36秒

课时106

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

10分24秒

课时107

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

4分2秒

课时108

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

17分39秒

课时109

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

10分41秒

课时110

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

6分15秒

课时111

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

17分26秒

课时112

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

17分10秒

课时113

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

6分58秒

课时114

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

7分53秒

课时115

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

19分26秒

课时116

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

16分2秒

课时117

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

17分54秒

课时118

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

4分26秒

课时119

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

17分24秒

课时120

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

14分47秒

课时121

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

8分27秒

课时122

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

7分27秒

课时123

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

10分12秒

课时124

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

14分28秒

课时125

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

7分9秒

课时126

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

7分34秒

课时127

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

2分43秒

课时128

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

13分58秒

课时129

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

19分58秒

课时130

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

12分36秒

课时131

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

16分47秒

课时132

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

8分8秒

课时133

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

8分23秒

课时134

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

11分34秒

课时135

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

9分25秒

课时136

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

8分24秒

课时137

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

8分4秒

课时138

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

7分34秒

章节7:第五-2Kubenetes基于DockerRuntime部署 (10节)

课时139

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

4分44秒

课时140

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

7分14秒

课时141

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

7分11秒

课时142

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

9分15秒

课时143

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

7分42秒

课时144

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

4分21秒

课时145

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

8分32秒

课时146

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

5分47秒

课时147

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

6分54秒

课时148

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

6分56秒

章节8:第六章 - Flink编程模型与API (65节)

课时149

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

2分16秒

课时150

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

8分12秒

课时151

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

17分29秒

课时152

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

19分20秒

课时153

05-Flink FileSource - Java代码实现

18分34秒

课时154

06-Flink FileSource - Scala 代码实现

6分39秒

课时155

07-Flink CollectionSource -Java 代码实现

6分42秒

课时156

08-Flink CollectionSource -Scala 代码实现

5分29秒

课时157

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

9分9秒

课时158

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

4分56秒

课时159

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

10分45秒

课时160

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

9分5秒

课时161

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

16分23秒

课时162

14-Flink ParallelSourceFunction-Java代码实现

5分32秒

课时163

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

7分56秒

课时164

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

2分34秒

课时165

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

4分15秒

课时166

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

5分3秒

课时167

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

3分50秒

课时168

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

7分58秒

课时169

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

10分1秒

课时170

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

4分15秒

课时171

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

7分4秒

课时172

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

4分17秒

课时173

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

11分8秒

课时174

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

11分0秒

课时175

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

10分13秒

课时176

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

9分5秒

课时177

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

3分42秒

课时178

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

22分44秒

课时179

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

9分52秒

课时180

32-Flink Sink - FileSink Java代码实现

20分20秒

课时181

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

6分29秒

课时182

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

18分30秒

课时183

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

13分56秒

课时184

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

15分58秒

课时185

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

5分6秒

课时186

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

14分35秒

课时187

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

9分54秒

课时188

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

7分5秒

课时189

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

4分47秒

课时190

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

17分42秒

课时191

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

7分28秒

课时192

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

18分32秒

课时193

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

14分33秒

课时194

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

10分54秒

课时195

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

4分56秒

课时196

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

11分42秒

课时197

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

6分27秒

课时198

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

14分0秒

课时199

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

9分27秒

课时200

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

4分13秒

课时201

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

14分10秒

课时202

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

8分6秒

课时203

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

16分56秒

课时204

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

7分4秒

课时205

57-Flink ProcessFunction - ProcessFun介绍

9分51秒

课时206

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

更新时间:2023-11-07

30分45秒

课时207

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

13分59秒

课时208

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

7分43秒

课时209

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

25分15秒

课时210

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

18分28秒

课时211

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

16分1秒

课时212

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

9分46秒

课时213

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

10分17秒

章节9:第七章 - Flin状态与容错 (35节)

课时214

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

3分19秒

课时215

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

20分29秒

课时216

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

23分51秒

课时217

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

12分3秒

课时218

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

18分38秒

课时219

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

10分18秒

课时220

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

13分21秒

课时221

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

10分10秒

课时222

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

17分30秒

课时223

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

10分23秒

课时224

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

11分34秒

课时225

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

7分22秒

课时226

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

15分13秒

课时227

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

6分54秒

课时228

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

16分23秒

课时229

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

24分40秒

课时230

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

3分54秒

课时231

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

15分22秒

课时232

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

26分44秒

课时233

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

12分3秒

课时234

21-Checkpoint 容错原理 - Checkpoint Barrier

14分24秒

课时235

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

24分58秒

课时236

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

18分56秒

课时237

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

11分45秒

课时238

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

12分31秒

课时239

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

12分19秒

课时240

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

16分29秒

课时241

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

21分13秒

课时242

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

27分46秒

课时243

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

20分21秒

课时244

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

21分49秒

课时245

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

5分31秒

课时246

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

16分32秒

课时247

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

12分51秒

课时248

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

9分42秒

您没有该体系课权限,需要开通权限请点击联系老师。
联系老师
个问题,0回答
提问
暂无提问,赶紧去提问吧~