多易教育 flink

后端开发

课程简介

Flink 实战：从理论到工程落地的核心跨越在实际的大数据后端开发场景中，很多开发者止步于 API 的简单调用，面对实时计算中的复杂业务逻辑时往往束手无策。本课程聚焦 Apache Flink 这一流批一体计算引擎，旨在解决从基础概念理解到复杂工程实践之间的断层问题。它不仅仅讲解 Flink 的运行原理，更侧重于在真实业务背景下如何设计高可用、低延迟的数…

已有 0 人浏览发布 2026-10-08 更新 2026-10-07

Flink 实战：从理论到工程落地的核心跨越

在实际的大数据后端开发场景中，很多开发者止步于 API 的简单调用，面对实时计算中的复杂业务逻辑时往往束手无策。本课程聚焦 Apache Flink 这一流批一体计算引擎，旨在解决从基础概念理解到复杂工程实践之间的断层问题。它不仅仅讲解 Flink 的运行原理，更侧重于在真实业务背景下如何设计高可用、低延迟的数据处理流水线。通过深入剖析窗口机制、状态管理、查表系统以及数据一致性保障等核心痛点，帮助开发者构建起完整的实时计算知识体系，从而能够独立应对企业级流数据处理挑战。

学习路径与资源配合建议

本课程适合具备 Java 或 Scala 基础，并熟悉 Hadoop、Hive 等大数据生态圈基础组件的开发者。对于完全没有分布式系统概念的初学者，建议先补齐 Java 并发编程和 Linux 基础操作的相关知识。在学习顺序上，建议优先掌握 Flink 的核心架构与 DataStream API，这是构建一切复杂应用的基石。随后，重点攻克窗口函数、Time语义以及状态后端配置，这些是解决数据乱序和故障恢复的关键。只有在深入理解了底层机制后，才能熟练运用 Table API 和 SQL 进行高效的数据挖掘和分析。

课程资料包中包含了大量可运行的源码示例和配置文件，这些是学习的核心资产。读者不应仅仅作为观看视频的对象，而应将这些源码下载下来，在实际开发环境中进行调试、修改和扩展。通过对照源码分析 Flink 任务提交、数据流转以及结果输出的完整链路，可以将抽象的理论转化为具体的工程能力。建议在完成每一个核心模块的学习后，尝试复现其中的关键案例，并思考如何将其应用到实际的业务场景中，例如实时日志分析、用户行为监控或金融交易风控等领域。

学完后的能力预期与独立实践

完成本课程的系统学习后，开发者将具备独立设计和实现复杂 Flink 实时计算任务的能力。具体而言，能够熟练编写 DataStream 程序处理无界数据流，合理配置 Checkpoint 和 Savepoint 以保障数据的一致性和系统的容错性，并能针对特定业务场景优化并行度、背压和内存使用。更重要的是，你将建立起从数据源接入、实时计算处理到结果sink输出的端到端开发思维，能够基于 Flink 搭建稳定可靠的大数据实时处理平台，为后续从事大数据ETL工程师、实时计算专家等高薪职位打下坚实的技术基础。

课程介绍

多易教育,专注于大数据领域各类开发技能培训,已帮助数以万计的技术青年走上大数据开发高薪职业之路,公司主要的培训班有Java大数据平台开发就业培训,大数据数据仓库开发就业培训,大数据ETL工程师就…

课程目录

flink.png (45.59 KB, 下载次数: 0) 2023-4-19 22:16 上传 课程介绍： 多易教育,专注于大数据领域各类开发技能培训,已帮助数以万计的技术青年走上大数据开发高薪职业之路,公司主要的培训班有Java大数据平台开发就业培训,大数据数据仓库开发就业培训,大数据ETL工程师就… 课程目录： flink资料 flink-day01 flink-day02 flink-day03 flink-day04 flink-day05 flink-day06 flink-day07 flink-day08 flink-day09 flink-day10 视频-day01 01Flink为什么这么火.mp4 243.14M 02Flink简介.mp4 330.48M 03Flink的standalone环境搭建.mp4 236.37M 04向flink集群提交job.mp4 218.06M 05创建flink的java项目模板.mp4 128.85M 06使用java编写实时WordCount.mp4 286.72M 07上一个程序的优化.mp4 227.42M 08使用javaLambda编写WordCount.mp4 290.97M 09使用scala编写WordCount.mp4 171.32M 10打包上传集群中执行.mp4 102.36M 11Source的并行度问题.mp4 334.48M 12lSource-ocal模式引入webui.mp4 142.15M 13Source-单并行的Source.mp4 187.37M 14Source-多并行的Source.mp4 195.66M 15Source-readFile的使用.mp4 190.13M 16Source-readTextFile的使用.mp4 168.44M 17Source-KafkaSource.mp4 350.16M 视频-day02 18Source-自定义Source01.mp4 171.64M 19Source-自定义Source02.mp4 304.56M 20Sink-printSink底层实现.mp4 254.30M 21Sink-writeAsText的使用.mp4 69.23M 22Sink-writeToSocke的使用.mp4 56.85M 23Sink-kafkaSink的使用.mp4 108.46M 24Sink-redisSink的使用.mp4 163.60M 25Sink-StreamingFileSink的使用.mp4 111.15M 26Sink-JDBCSink的使用.mp4 99.90M 27Transformation-map的基本使用.mp4 139.75M 28Transformation-map底层的实现.mp4 239.51M 29Transformation-flatMap底层实现.mp4 183.33M 30Transformation-filter底层的实现.mp4 119.32M 31Transformation-key的用法1.mp4 178.11M 32Transformation-key的用法2.mp4 133.35M 33Transformation-key的用法3.mp4 105.10M 视频-day03 35Transformation-reduce源码分析.mp4 184.29M 36Transformation-keyBy底层源码分析.mp4 268.65M 37Transformation-fold底层实现.mp4 73.17M 38Transformation-min底层实现.mp4 199.91M 38Transformation-sum底层实现.mp4 188.02M 39Transformation-min和minBy的区别.mp4 153.19M 40Transformation-union的使用.mp4 130.22M 41Transformation-connect的使用.mp4 142.39M 42Transformation-Iterate的使用.mp4 122.04M 43Transformation-project的使用.mp4 114.82M 44Transformation-split和select的使用.mp4 105.95M 45Transformation-rebalance的使用.mp4 208.68M 46Transformation-shuffle的使用.mp4 93.75M 47Transformation-Broadcast的使用.mp4 50.98M 48Transformation-rescaling的使用.mp4 36.59M 49Transformation-partitionCustom的使用.mp4 90.32M 视频-day04 50Flink的窗口和时间.mp4 123.45M 51Flink的窗口类型.mp4 145.00M 52CountWindow的使用.mp4 174.88M 53WindowFunction增量聚合.mp4 134.27M 54Window数据全量聚合.mp4 143.42M 55Window数据全量排序.mp4 47.40M 56Keyed的CountWindow.mp4 88.28M 57Keyed的CountWindow聚合.mp4 56.93M 58NoKeyedProcessingTime滚动窗口.mp4 158.27M 59KeyedProcessTime滚动窗口.mp4 147.31M 60NoKeyedProcessingTime滑动窗口.mp4 173.07M 61KeyedProcessingTime滑动窗口.mp4 118.41M 62NoKeyedProcessingTime会话窗口.mp4 47.42M 63KeyedProcessingTime会话窗口.mp4 71.03M 64NoKeyedEventTime滚动窗口.mp4 273.00M 65KeyedEventTime滚动窗口..mp4 265.50M 66多分区生成watermark窗口触发条件.mp4 171.44M 67EventTime会话窗口.mp4 66.26M 68WaterMark使用和详解.mp4 143.09M 视频-day05 69案例-关联mysql查询维度数据.mp4 336.84M 70案例-使用httpclient查询高德地图.mp4 209.11M 71窗口join的使用.mp4 311.68M 72窗口leftOuterJoin的使用.mp4 189.46M 73intervalJoin的使用.mp4 202.18M 74flink的task划分.mp4 174.97M 75flink共享资源槽.mp4 116.99M 76task算子链.mp4 159.82M 77startNewChain的使用.mp4 83.54M 78disableChaining的使用.mp4 40.74M 79设置资源槽组名称.mp4 215.88M 视频-day06 80为什么需要state.mp4 106.45M 81flink容错相关概念.mp4 103.07M 82固定次数重启策略.mp4 179.13M 83错误率重启策略.mp4 235.38M 84使用hashMap模拟KeyedState.mp4 160.15M 85自己实现一个简单的KeyedState.mp4 256.76M 86ValueState的基本使用.mp4 205.24M 87ValueState底层源码分析.mp4 245.52M 88MapState的使用和原理.mp4 213.50M 89ListState的使用和原理.mp4 148.00M 90使用ValueState实现ListState.mp4 100.82M 91Operator和KeyedState的区别.mp4 162.33M 92OperatorSate案例需求.mp4 40.65M 93使用OperatorState实现AtLeastOnceSource.mp4 463.11M 视频-day09 134flinkKafkaProduce实现ExactlyOnce.mp4 216.03M 135checkpoint完整过程.mp4 157.13M 136实现ExactlyOnce代码.mp4 545.20M 137数据采集架构.mp4 163.23M 138openresty安装.mp4 88.35M 139openresty整合lua.mp4 263.03M 140flume整合kafka.mp4 221.48M 141nginx的kafka-module.mp4 310.14M 视频-day10 142FlinkUtils工具类编写.mp4 114.39M 143工具类完善.mp4 174.84M 144数据预处理需求.mp4 122.02M 145数据预处理测试.mp4 616.01M 146布隆过滤器结合TTL.mp4 80.42M 147布隆过滤器结合TTL实现.mp4 425.62M 148热门商品topN需求.mp4 70.27M 149热门商品topN实现.mp4 360.47M 视频day07 100侧流输出获取窗口迟到的数据.mp4 184.88M 101WindowFunction的使用.mp4 214.76M 102aggregate结合windowFunction.mp4 206.98M 103ProcessWindowFunction的使用.mp4 150.43M 94ProcessFunction的使用.mp4 228.78M 95KeyedProcessFunction的使用.mp4 56.41M 96注册定时器OnTimer.mp4 245.28M 97注册订单群并集合ValueState聚合.mp4 143.66M 98OnTimer触发的时机.mp4 112.62M 99侧流输出.mp4 216.18M 视频day08 104State的TTL存活时间.mp4 247.79M 105案例-统计去重人数.mp4 331.04M 106BroadcastState的使用.mp4 550.32M 107QueryableState的使用.mp4 187.22M 108异步IO的使用.mp4 341.44M 109数据一致性的实现.mp4 254.45M 110向hdfs写checkpoint的出错问题.mp4 197.54M 111向hdfs写checkpoint的出依赖.mp4 275.81M 112flink的job重启从checkpoint恢复.mp4 141.29M 113checkpoint和savepoint的区别.mp4 117.47M