简介:本课程包含Flink重要的概念和编程模型,FlinkDataset和DataStreamAPI详解,Flink Table和SQL的算子操作以及在实际问题中的应用。并且通过案例入手讲解FlinkSQL在生产环境的使用。
第1章 课程介绍
本章主要从Flink最新版本的新特性入手,介绍了Flink的核心概念和编程模型,以及Flink未来的发展方向、FlinkSQL的优势和生产应用。
第2章 Flink的编程模型和核心概念
本章主要讲解Flink的编程模型和核心概念,包括包括水印、并行度、时间窗口、以及FlinkSQL的基本概念,并通过案例实操介绍SQL的编程模型。
第4章 Flink Table和SQL的编程模型
本章主要讲解了Flink Table和SQL的编程模型以及常用的算子操作,并且介绍了SQL自带的内置函数以及用户如何自定义函数,以便于同学们能够了解FlinkSQL的基础使用。
第5章 实战项目---NBA球星得分王排行榜
本章案例主要从NBA球星的得分数据入手,带领同学们完成使用FlinkSQL处理数据并且计算出得分排行的功能。
第6章 实战项目---流式计算中的应用
本章介绍了Kafka的核心概念以及本地环境的搭建,并结合案例讲解了如何使用Flink消费Kafka数据,实现FlinkSQL在实时流式环境中的应用。