课程试听
第一章 Flink概述
1-1 Flink概述
- 1-0-1Flink课程学习内容介绍【了解】 免费试学
- 1-1-1Flink的引入【了解】 免费试学
- 1-2-1什么是Flink以及Flink流处理的特性【了解】 免费试学
- 1-3-1Flink的四大基石【重点理解】 免费试学
- 1-4-1Flink流处理和批处理【了解】 免费试学
第二章 Flink架构体系
2-1 Flink架构体系
- 2-1-1Flink中的角色以及无界数据流【掌握】 免费试学
- 2-2-1Flink的编程模型【重点理解】 免费试学
- 2-3-1Flink的集成及整合【了解】 免费试学
第三章 Flink集群搭建
3-1 Flink集群搭建-本课程所有资料在此下载
- 3-1-1Flink集群单间环境准备工作【了解】
- 3-2-1Flink安装模式之local模式【了解】
- 3-3-1Flink集群搭建-standalone模式【掌握】
- 3-4-1Flink-standaloneHA模式【掌握】
- 3-5-1Flink-on-yarn的session会话模式【掌握】
- 3-6-1Flink的编程模型与并行流介绍【了解】
- 3-6-2Flink中调度执行【理解】
- 3-6-3Slot以及Slotsharing【理解】
第四章 Flink批处理编程
4-1 Flink批处理编程
- 4-1-1Flink入门案例-批处理-wordcount【掌握】
- 4-1-2Flink入门案例-onyanr模式运行【掌握】
- 4-2-1Flink批处理DataSource之基于集合【了解】
- 4-2-2Flink批处理DataSource之基于文件【了解】
- 4-3-1Flink-transformation-map和mappartition【掌握】
- 4-3-2Flink-transformation-flatMap和filter操作【掌握】
- 4-3-3Flink-transformation-reducegroup aggregate distinct操作【了解】
- 4-3-4Flink-tansformation-join之leftjoin操作【掌握】
- 4-3-5Flink-transformation-rightouterjoin和fullouterjoin操作【掌握】
- 4-3-6Flink-transformation-rebalance操作【掌握】
- 4-3-7Flink-transformation-分区策略【了解】
- 4-3-8Flink-transformation-minby maxby cross操作【了解】
- 4-4-1Flink-sink操作【了解】
- 4-5-1Flink执行模式【了解】
- 4-6-1Flink中广播变量【掌握】
- 4-7-1Flink中累加器使用【掌握】
- 4-8-1Flink的分布式缓存【掌握】
- 4-9-1Flink程序并行度设置级别【了解】
第五章 Flink流处理编程
5-1 Flink流处理编程
- 5-1-1Flink-stream入门案例-wordcount【了解】
- 5-2-1Flink中基于集合和文件的source【了解】
- 5-2-2自定义非并行数据源【掌握】
- 5-2-3Flink中自定义并行数据源与富有并行数据源【掌握】
- 5-2-4生成订单数据自定义source【练习】
- 5-2-5自定义mysqlsource【掌握】
- 5-2-6Flink中Kafka Source和Kafka Consumer配置【练习】
- 5-3-1Stream中keyby和connect操作【练习】
- 5-3-2Stream中split和select操作【练习】
- 5-4-1自定义MySQLSink【理解】
- 5-4-2Flink Stream保存数据到Kafka【掌握】
- 5-4-3Flink使用RedisSink保存数据到Redis【掌握】
第六章 Flink窗口
6-1 Flink窗口
- 6-1-1Flink中窗口介绍【理解】
- 6-2-1Window操作案例【掌握】
- 6-3-1Flink中的Count Window案例【掌握】
- 6-4-1我indow的Apply方法案例【掌握】
第七章 Flink EventTime-Watermark
7-1 Flink EventTime-Watermark
- 7-1-1Flink时间分类【理解】
- 7-2-1Watermark引入【理解】
- 7-2-2Flink基于事件时间与Watermark解决数据延迟的原理分析【理解】
- 7-3-1Flink添加水印案例实现与窗口源码解析【掌握】
- 7-3-2Watermark手动实现方式【了解】
- 7-4-1再次理解Watermark-数据是否丢失【理解】
- 7-5-1allowedLateness和侧道输出保证数据不丢失【理解】
- 7-5-2侧道输出和allowedLateness案例实现【掌握】
第八章 Flink的状态管理
8-1 Flink的状态管理
- 8-1-1Flink中State是什么【理解】
- 8-2-1Flink中State的类型【理解】
- 8-2-2ValueState的使用案例【练习】
- 8-2-3MapState使用案例【练习】
- 8-2-4OperatorState案例【练习】
- 8-2-5OperatorState之liststate案例【练习】
- 8-2-6Flink Broadcast State简介与API介绍【理解】
- 8-2-7Broadcast State案例准备工作【理解】
- 8-2-8Broadcast State案例第一部分消费Kafka事件流代码编写【练习】
- 8-2-9Broadcast State案例自定义读取MySQL数据并进行广播操作【练习】
- 8-2-10Broadcast State案例processfunction处理connectedstream【练习】
第九章 Flink的容错
9-1 Flink的容错
- 9-0-1Flink容错概述【了解】
- 9-1-1Checkpoint介绍以及工作流程【理解】
- 9-1-2Flink Checkpoint三种存储介质介绍【理解】
- 9-1-3Flink程序设置Checkpont属性设置1【掌握】
- 9-1-4Flink Checkpoint属性配置2【掌握】
- 9-2-1Flink重启策略【掌握】
- 9-3-1Flink Savepoint介绍及演示【理解】
- 9-4-1Flink一致性语义讨论【理解】
- 9-4-2Flink端到端一致性两阶段提交协议分析【理解】
- 9-4-3Flink加Kafka保证一致性语义【掌握】
- 9-4-4Kafka到MySQL一致性案例【理解】
第十章 Flink扩展知识
10-1 Flink扩展知识
- 10-1-1Flink异步IO介绍与API简介【理解】
- 10-1-2异步IO案例【掌握】
- 10-2-1Flink背压机制【理解】
- 10-3-1Flink的内存管理介绍【理解】
第十一章 Flink SQL编程
11-1 Flink SQL编程
- 11-1-1Flink批处理SQL案例【掌握】
- 11-2-1流处理SQL案例及总结【掌握】