大家好,欢迎来到IT知识分享网。
对flink知识点进行简单梳理,及每个功能点的代码实现。本地运行只需要更改/resource/conf下的配置信息,可直接运行。路过的大老爷们,点个星呗(你们的赞是我坚持写下去的动力!!) 项目持续更新中。。。
GitHub – perkinls/flink-local-train: flink入门到项目实践
1.知识点梳理
-
DataStream Api
-
DataSet Api
-
Table Api
-
flink对接kafka数据源
-
自定义反序列化器
-
WaterMark机制
-
触发器Trigger
-
窗口函数Window
-
侧输出(乱序、分流)
-
Flink异步IO
-
不同数据流join操作
-
Sink操作(hbase、mysql、redis)
-
状态管理 待更新。。。
2.项目实战
关注公众号 `数据工匠记` ,专注于大数据领域离线、实时技术干货定期分享!个人网站 [www.lllpan.top](http://www.lllpan.top)
![在这里插入图片描述](https://img-blog.csdnimg.cn/20210326133950297.png#pic_center)
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/6259.html