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

01 | 课程介绍

时长 07:02

02 | 内容综述

时长 02:47

03 | 流处理技术概览

时长 13:44

04 | Flink发展历史与应用场景

时长 06:24

05 | Flink核心特性

时长 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

25 | Windows窗口计算

时长 10:10

26 | Window Assigner

时长 10:38

27 | Window Trigger

时长 14:17

28 | Window Evictors

时长 07:57

29 | Window Function

时长 24:20

30 | Windows多流合并

时长 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

73|Dispatcher任务分发器

时长 17:44

74|JobGraph提交与运行(上)

时长 22:23

75|JobGraph提交与运行(下)

时长 25:49

76|Task执行与调度

时长 23:32

77|Task重启和容错策略

时长 14:17

78|集群组件RPC通信机制

时长 18:06

79|NetworkStatck实现原理

时长 22:10

80|Flink内存管理

时长 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实践与应用

时长 20:33

87|Flink复杂事件处理:Complex event process

时长 20:31

88|Alink机器学习框架介绍与使用

时长 13:40

89|Stateful Function介绍与使用

时长 18:18
第九章:项目实战-使用Flink构建推荐系统实时数据流 (2讲)

90|实时推荐系统项目设计与实现

时长 13:54

91|结束语
隐藏内容

此处内容需要权限查看

  • 普通用户购买价格:1金币
  • 会员用户购买价格:免费
  • 永久会员用户购买价格:免费推荐
会员免费查看

时长 06:17

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注