实验 2
Flink 部署模式
知识点: 1.介绍Flink的三种部署模式 2.搭建Standalone伪分布式集群 3.向集群提交WordCount任务
实验 3
流处理之基础算子
知识点: 1.流处理流程 2.基础算子 3.map 4.filter 5.flatMap
实验 4
流处理之基于 Key 的算子
知识点: 1.KeyBy 2.RollingAggregation 3.sum 4.min 5.max 6.minBy 7.maxBy 8.reduce
实验 5
流处理之基于多流转换算子
知识点: 1.Union 2.Split和Select
实验 6
Source 与 Sink
知识点: 1.Source 2.从文件读取数据 3.从Socket读取数据 4.从集合读取数据 5.自定义Source 6.Sink 7.写入文件（txt） 8.写入Socket 9.自定义Sink
实验 7
Flink 状态管理
知识点: 1.State分类 2.KeyedState 3.OperatorState 4.Checkpoint 5.StateBackend
实验 8
Flink 架构介绍
知识点: 1.JobManager 2.ResourceManager 3.TaskManager 4.Dispatcher 5.Slots
实验 9
Flink 中的窗口
知识点: 1.Window分类 2.KeyedWindow和GlobalWindow 3.TimeWindow和CountWindow 4.WindowAPI
实验 10
Time 和 WaterMark
知识点: 1.Time 2.EventTime 3.IngestionTime 4.ProcessingTime 5.Watermark 6.Watermark的概念 7.Watermark的使用
实验 11
Table API 和 SQL
知识点: 1.Maven依赖 2.TableAPI 3.FlinkSQL
本文由 liyunfei 创作，采用 知识共享署名4.0
国际许可协议进行许可
本站文章除注明转载/出处外，均为本站原创或翻译，转载前请务必署名
最后编辑时间为: Jun 24,2022