2. TableAPI 的 MySQL 及 Hive 数据源输入-Flink 实时处理实战-极客时间

Flink 实时处理实战

王超( 老王)

大数据资深讲师

1 人已学习

新⼈⾸单¥98

课程目录

已完结/共 37 讲

第一章：实时处理利器：Flink（一） (5讲)



1. Flink 的基本介绍

时长 18:35

2. Flink 的集群架构及集群运行

时长 25:45

3. Flink 的入门案例及并行度设置

时长 23:03

4. 数据源及 DataStream 转换算子

时长 32:03

5. DataSet 转换算子

时长 18:32

第二章：实时处理利器：Flink（二） (4讲)



1. Flink 中的 connector

时长 22:17

2. 计数器累加器、分布式缓存和 Task 数据传输策略

时长 27:06

3. Flink 的四层模型和 State

时长 20:33

4. Flink 的 ValueState、ListState 操作

时长 26:03

第三章：实时处理利器：Flink（三） (8讲)



1. Flink 的 mapState、reduceingState 等操作

时长 23:06

时长 18:07

时长 28:07

时长 17:08

时长 17:36

时长 19:06

时长 24:36

时长 22:02

第四章：实时处理利器：Flink（四） (7讲)



1. Flink 的数据增量聚合及全量聚合

时长 33:07

2. Flink 的 watermark 机制和顺序数据的 watermark

时长 30:04

3. 使用 watermark 机制处理乱序数据

时长 29:01

4. 用 connect 实现两个流数据的 join 操作

时长 29:32

5. 三种窗口类型的数据关联

时长 19:06

6. TableAPI 和 SQL 的基本介绍

时长 23:04

7. Flink 的基本编程

时长 26:34

第五章：实时处理利器：Flink（五） (7讲)



1. TableAPI 的各种数据源输入

时长 25:51

2. TableAPI 的 MySQL 及 Hive 数据源输入

时长 17:03

3. TableAPI 的数据输出

时长 30:25

4. FlinkSQL 的语法

时长 29:41

5. TableAPI 基于窗口的操作简介

时长 25:35

6. TableAPI 基于滑动窗口、会话窗口的操作

时长 27:16

7. TableAPI 基于 OverWindow 的操作

时长 26:32

第六章：实时处理利器：Flink（六） (6讲)



1. FlinkSQL 基于 GroupWindow 的操作

时长 25:10

2. FlinkSQL 基于 OverWindow 的操作

时长 12:45

3. FlinkSQL 的自定义 UDF、UDTF 函数

时长 41:38

4. FlinkSQL 的自定义 UDAF 函数

时长 15:11

5. Flink 的 CEP 复杂事件处理

时长 30:47

6. CEP 实战案例

时长 32:24

