big-data/flink_book

Flink学习笔记，持续更新。。。暂时先学习Hadoop。。

flink java

Go to file

zeekling 541b57faf1 更新roscksdb相关		2023-09-23 14:41:53 +08:00
basic	更新roscksdb相关	2023-09-23 14:41:30 +08:00
Flink_SQL	将图片移动到cdn上面 (#22 )	2023-07-01 12:05:45 +00:00
hudi	Hudi知识点总结 (#24 )	2023-07-31 15:20:40 +00:00
rocksdb	更新roscksdb相关	2023-09-23 14:41:53 +08:00
source_code	增加rpc	2023-04-22 23:40:34 +08:00
常见问题	学习Flink常见问题处理	2023-01-30 23:58:44 +08:00
调优	checkpoint相关 (#29 )	2023-09-03 14:13:40 +00:00
.imgbotconfig	Image bot (#5 )	2023-01-01 12:42:44 +08:00
LICENSE	Initial commit	2022-12-11 21:41:41 +08:00
README.md	格式调整优化 (#23 )	2023-07-17 15:23:29 +00:00
reference.md	添加Flink学习参考博客等 (#31 )	2023-09-17 15:19:50 +00:00

README.md

简介

本项目用于学习Flink所做的笔记，便于以后查看复习。此项目适合我这种虽然比较菜，且爱学习的人学习。

内存调优

目录

常见故障排除

目录

常见问题总结

Flink SQL

Flink SQL学习笔记提纲。持续更新。Hive SQL 离线Join VS Flink SQL 双流Join。

对比维度	Hive SQL离线Join	Flink SQL双流Join
数据源	有界(离线数据)	无界(实时数据)
计算次数	一次	持续计算
计算结果	有界(离线数据)	无界(实时数据)
计算驱动	单边驱动	双边驱动

目录

基础知识

FLink基础知识

Flink On Hudi

Flink On Hudi 简介

Flink 源码

源码编译可以使用下面命令

mvn install -DskipTests -Dfast -Dpmd.skip=true -Dcheckstyle.skip=true \
-Dmaven.javadoc.skip=true -Dmaven.compile.fork=true

缺的包可以在 https://conjars.org/repo/org/pentaho/pentaho-aggdesigner-core/5.1.5-jhyde/

https://packages.confluent.io/maven/io/confluent/kafka-schema-registry-client/7.2.2/ 下面找到。

目录