对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)
今天的文章flink入门到项目(完整教程)分享到此就结束了,感谢您的阅读,如果确实帮到您,您可以动动手指转发给其他人。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/30088.html