教程目录
01、Flink 基础 - Flink介绍;
02、Flink 基础 - Flink部署;
03、Flink 基础 - windows安装Flink;
04、Flink 基础 - CDH6.3集成Flink1.9;
05、Flink 基础 - Flink 配置文件参数;
06、Flink 基础 - flink run参数;
07、Flink 基础 - 通过Web UI执行jar文件;
08、Flink 基础 - Flink on yarn运行wordcount程序;
09、Flink 基础 - Flink运行架构;
10、Flink 基础 - Flink Environment;
11、Flink 基础 - Source之从集合读取数据;
12、Flink 基础 - Source之从文件读取;
13、Flink 基础 - Source之从Kafka读取;
14、Flink 基础 - Source之自定义Source;
15、Flink 基础 - Tranform之基本转换算子(map/flatMap/filter);
16、Flink 基础 - Tranform之聚合操作算子;
17、Flink 基础 - Tranform之多流转换算子;
18、Flink 基础 - 支持的数据类型;
19、Flink 基础 - 实现UDF;
20、Flink 基础 - 数据重分区操作;
21、Flink 基础 - Sink之Kafka;
22、Flink 基础 - Sink之Redis;
23、Flink 基础 - Sink之JDBC;
24、Flink 基础 - Flink的Window;
25、Flink 基础 - 时间语义和Watermark;
26、Flink 基础 - Flink状态管理;
27、Flink 基础 - ProcessFunction API(底层API);
28、Flink 基础 - Flink容错机制;
29、Flink 基础 - Table API和Flink SQL之整体介绍;
30、Flink 基础 - Table API和Flink SQL之API调用;
31、Flink 基础 - Table API和Flink SQL之流处理中的特殊概念;
32、Flink 基础 - Table API和Flink SQL之窗口;
33、Flink 基础 - Table API和Flink SQL之函数;
34、Flink 基础 - Flink CEP简介;
35、Flink 基础 - Flink CDC简介;
36、Flink项目 1、项目介绍;
37、Flink项目 2、实时热门商品统计;
38、Flink项目 3、实时流量统计;
39、Flink项目 4、市场营销商业指标统计分析;
40、Flink项目 5、恶意登录监控;
41、Flink项目 6、订单支付实时监控;
42、Flink报错案例 1-本地运行Flink报错java.lang.NoClassDefFoundError;
43、Flink报错案例 2-提交到yarn集群报错java.lang.NoClassDefFoundError FlinkKafkaConsumer;
44、CDH 6.3 大数据平台搭建;