1. 简介
很多朋友在学习Flink的时候都希望能有个demo代码来参考实践,于是在百度或者Google一顿搜索,虽然能找到很多demo代码,但是这些demo要么版本比较旧,要么代码不全,根本跑不通。
其实,Flink官网就提供了很多可供参考的demo代码,只需要拉取Flink源码子项目flink-examples即可。
2. 获取flink-examples子项目
2.1 拉取 flink 源代码
git clone https://github.com/apache/flink.git
2.2 切换到1.16版本的代码
git checkout remotes/origin/release-1.16
demo代码就在flink/flink-examples目录下
3. 使用IntelliJ IDEA 打开flink-examples项目
flink-examples下还有三个子项目:
flink-examples-batch
: 批处理demo
flink-exampls-streaming
: 流处理demo
flink-exmaples-table
: table demo
以flink-exampls-streaming
为例, 包含了flink流式处理丰富的例子,如窗口,状态,join,测流输出,异步IO等。
本篇到此结束,欢迎订阅Flink专栏,学习更多Flink的相关知识。