值不值得学:先看清它解决什么工作场景

这份 Flink 教程对应的实际工作场景很明确,就是处理那些“晚来一秒就没价值”的数据。比如电商大促时的实时成交看板、风控系统里要秒级拦截的异常交易,或者物联网设备上报的传感器数据流。如果你平时接触的都是跑批任务,比如每天凌晨用脚本拉取前一天的数据出报表,那这门课能帮你补齐“实时流处理”这块拼图。它解决的核心痛点是:当数据像流水一样源源不断涌来时,怎么用一套框架高效接住、清洗、聚合并输出结果。如果你目前的工作完全不涉及数据开发,连基础的 Java 或 Scala 语法都看不懂,建议先补语言基础,这门课的门槛不在框架本身,而在你对数据处理的底层认知。

怎么用资料:先看哪几块,怎么配合练习

这份资料是典型的视频教学,没有配套的图文文档,所以别指望像看小说一样泛读。建议的顺序是:先跳过前几节的理论介绍,直接去看“无界流代码处理流程”和“源算子从集合文件中模拟数据演示”这两块。先跟着把本地环境跑通,用集合模拟数据敲出第一行能跑起来的代码,建立手感。然后再折返回去看离线与实时计算的原理剖析,这时候你脑子里有了代码画面的概念,听原理就不会觉得干瘪。接着重点去啃 Kafka 新老版本的源算子接入,这是真正在实际项目里最常用的场景。练习时,别只是看视频里的代码截图,一定要自己在本地起一个 Kafka 服务,造一点测试数据,把消费链路完整跑一遍,遇到报错自己查文档解决,这比看十遍视频都管用。

学完能独立做什么:拆解到具体动作

把这套流处理框架的底层逻辑吃透后,你能独立完成的事情是很具体的。你能写出一个持续运行的流处理任务,从 Kafka 里实时读取用户点击日志,按时间窗口做简单的聚合统计,比如每分钟统计一次各页面的访问量,然后把结果写回到数据库或者另一个消息队列里。你也能看懂别人写的 Flink 任务代码,知道哪段是数据源、哪段是转换算子、哪段是输出。再不济,当团队里讨论实时数仓方案时,你能清楚知道这套框架能干什么不能干什么,不会盲目跟风。资料里的原理剖析部分,主要是帮你理解为什么要这么写代码,而不是让你去背八股文。重点放在把代码模板变成你自己手里能解决实际问题的工具,而不是纠结于每个算子的冷门参数。


老师通过图文解析,原理剖析,逐步深入的方式对Flink进行讲授,让学员知其然知其所以然。

课程目录

*   01 01Flink离线与实时计算的介绍.mp4 07:25

*   02 02Flink代码模板以及批处理代码讲解.mp4 09:03

*   03 03Flink用流式处理批处理代码实现讲解.mp4 09:22

*   04 04Flink无界流代码处理的流程讲解.mp4 06:55

*   05 05Flink的Lambda表达式写法.mp4 07:01

*   06 06Flink的Datestream的介绍.mp4 04:18

*   07 07Flink的批处理模式的介绍.mp4 09:04

*   08 08Flink的源算子介绍.mp4 03:00

*   09 09Flink的源算子从集合文件中模拟数据演示.mp4 06:39

*   10 10Flink的源算子kafka的新老版本的代码讲解.mp4 07:28

*   11 11Flink自定义source以及自定义多并行度案例.mp4 04:48

*   12 12Flink的转换算子操作-Map演示.mp4 05:36

*   13 13Flink的转换算子操作-filter演示.mp4 03:26

*   14 14Flink的转换算子操作-FlatMap演示.mp4 04:36

*   15 15Flink的聚合算子操作-keyby与max和maxby.mp4 16:56

*   16 16Flink的聚合算子操作-reduce的案例演示.mp4 06:56

*   17 17Flink的自定义函数RichFunction.mp4 06:43

*   18 18Flink的物理分区概念介绍.mp4 07:59

*   19 19Flink的物理分区代码演示.mp4 06:40

*   20 20Flink的sink算作-文件算子演示.mp4 02:30

*   21 21Flink的sink算子-kafka新老版本的演示.mp4 07:50

*   22 22Flink的sink算子-mysql演示.mp4 05:20

*   23 23Flink的合并算子-connect演示.mp4 03:09

*   24 24Flink的合并算子-union的演示.mp4 01:10

*   25 25Flink的时间语义-时间语义的概念.mp4 13:28

*   26 26Flink的时间语义-如何处理乱序数据.mp4 15:42

*   27 27Flink的时间语义-单进程watermark下游推算逻.mp4 15:06

*   28 28Flink的时间语义-多并行度Watermark下游推算.mp4 04:38

*   29 29Flink的window-窗口的介绍.mp4 10:55

*   30 30Flink的window-process统计演示.mp4 10:15

*   31 31Flink的window-countTime演示.mp4 06:55

*   32 32Flink的window-会话窗口的演示.mp4 02:13

*   33 33Flink的window-事件时间滚动演示.mp4 08:25

*   34 34Flink的window-事件时间滑动演示.mp4 03:36

*   35 35Flink的window-通过案例了解水位与窗口.mp4 07:44

*   36 36Flink的window-严重迟到数据处理流程演示.mp4 03:28

*   37 37flink的state-状态的概念介绍.mp4 12:51

*   38 38Flink的state-key的各种状态存储的演示.mp4 11:58

*   39 39Flink的检测点的代码讲解.mp4 06:52