77｜Task重启和容错策略-Flink核心技术与实战-极客时间

Flink 核心技术与实战

张利兵

第四范式数据中台架构师，Apache Flink 贡献者

16166 人已学习

新⼈⾸单¥68

课程目录

已完结/共 91 讲

第一章：Apache Flink介绍 (5讲)



时长 07:02

时长 02:47

时长 13:44

时长 06:24

时长 07:59

第二章：Flink部署与应用 (13讲)



06 | Flink集群架构

时长 19:58

07 | Flink集群运行模式

时长 17:21

08 | Flink集群资源管理器支持

时长 07:28

09 | Standalone原理讲解与实操演示

时长 23:53

10 | Flink On Yarn部署讲解

时长 18:33

11 | Flink On Yarn实操演示

时长 21:08

12 | Flink On Kubernetes部署讲解

时长 30:09

13 | Flink On Kubernetes实操：Session模式

时长 09:32

14 | Flink On Kubernetes实操：Per-job模式

时长 10:09

15 | Flink On Kubernetes Native部署讲解

时长 12:12

16 | Flink On Kubernetes Native实操演示

时长 13:42

17 | Flink高可用配置原理讲解

时长 09:17

18 | Flink高可用配置实操演示

时长 07:11

第三章：Flink DataStream API实践原理 (19讲)



19 | 分布式流处理模型

时长 04:44

20 | DataStream API实践原理

时长 31:34

21 | Flink时间概念

时长 06:23

22 | Watermark实践原理

时长 12:50

23 | Watermark与Window的关系

时长 17:46

24 | Watermark Generator

时长 17:01

时长 10:10

时长 10:38

时长 14:17

时长 07:57

时长 24:20

时长 18:15

31 | Process Function应用

时长 20:07

32 | SideOutput旁路输出

时长 10:53

33 | Asynchronous I/O异步操作

时长 20:51

34 | Pipeline与StreamGraph转换

时长 16:33

35 | Flink类型系统

时长 18:14

36 | 自定义SourceFunction

时长 17:57

37 | 项目实战：基于DataStream API实现PV，UV统计

时长 18:32

第四章：Flink状态管理和容错 (13讲)



38 | 有状态计算概念

时长 13:24

39 | 状态类型及应用

时长 10:03

40 | KeyedState介绍与使用

时长 09:54

41 | OperatorState介绍与使用

时长 19:34

42 | BroadcastState介绍与使用

时长 27:28

43 | Checkpoint实现原理

时长 20:24

44 | Savepoint与Checkpoint

时长 17:13

45 | StateBackends状态管理器

时长 16:09

46 | State Schema Evolution

时长 11:47

47 | State序列化与反序列化

时长 16:55

48 | Queryable State介绍与使用

时长 15:42

49｜项目实战：实时交易反欺诈项目介绍

时长 19:42

50｜项目实战：实时交易反欺诈项目演示

时长 12:23

第五章：Flink Table & SQL实践原理 (19讲)



51｜Flink Table API/SQL介绍与使用

时长 22:00

52｜Table API/SQL核心概念

时长 28:40

53｜DataStream & DataSet 与Table相互转换

时长 17:16

54｜Table Connector介绍与使用

时长 23:12

55｜Querying Dynamic Tables

时长 27:33

56｜TimeStamp与Watermark时间属性定义

时长 23:17

57｜Query With Temporal Condition

时长 17:55

58｜Join With Dynamic Table

时长 20:33

59｜Join With Temporal Function

时长 11:08

60｜Join With Temporal Tables

时长 12:04

61｜Catalog原理与使用

时长 14:43

62｜Apache Hive集成

时长 20:38

63｜SQL Client介绍与使用

时长 16:05

64｜Flink SQL Table数据类型

时长 19:55

65｜自定义Function

时长 21:04

66｜Table Connector使用

时长 13:37

67｜自定义Connector

时长 23:41

68｜new tablesource & tablesink api

时长 12:52

69｜项目实战：基于Flink SQL实现Top10商品统计

时长 17:30

第六章：Flink Runtime设计与实现 (11讲)



70｜Runtime整体架构

时长 15:57

71｜Flink Client实现原理

时长 19:54

72｜ResourceManager资源管理

时长 16:07

时长 17:44

时长 22:23

时长 25:49

时长 23:32

时长 14:17

时长 18:06

时长 22:10

时长 22:36

第七章：Flink监控与性能优化 (5讲)



81｜Metric指标分类与采集

时长 16:57

82｜Flink REST API介绍与使用

时长 10:25

83｜Checkpoint监控与调优

时长 28:00

84｜反压监控与原理

时长 18:48

85｜Flink内存配置与调优

时长 16:32

第八章：Flink组件栈介绍与使用 (4讲)



86｜PyFlink实践与应用