[Scala] Flink项目实例系列(零)
前言
项目基于尚硅谷的Flink教学视频,记录下来一是方便以后自己查看,二是丰富点互联网生活。学习嘛都是先模仿再创造,写完这份博客我就走完了前小部分路吧。
因为很感谢尚硅谷的开源教程,另百度云脾气不好数据量又大,综上几条我决定直接放官方链接——戳我一大批开源教程就都是你的了。
本项目的代码及文件见这这这,友情码是:3n9z。
再说一条我的体会,我是学Python入的坑,而大数据框架很多还是用Java和Scala的,所以教程实在太难找,而对于我来说,学习效率十分重要,所以最后还是把Scala学了一遍,然后,磨刀真香。
正题
传送区
后续内容请看传送门,放一页不好修改。
[Scala] Flink项目实例系列(零)
[Scala] Flink项目实时热门商品统计(一)
[Scala] Flink项目实时流量统计(二)
[Scala] Flink项目恶意登录监控(三)
[Scala] Flink项目订单支付失效监控(四)
[Scala] Flink项目订单支付实时对账(五)
[Scala] Flink项目小彩蛋(六)
项目亮点
- Flink的基本使用,包括map、filter、keyBy、connect、timeWindow等
- 各底层API的使用,包括AggregateFunction、ProcessFunction、OutputTag、State等
- CEP
- 布隆过滤器 + Redis
基础
丢完系统教程我就不提太多基础了,只是说声要学好 Flink 最好还是把基础撸好,最起码要了解数据流、Window 的概念、时间语义、WaterMark、Flink状态、CEP等,项目中运用较多。
关于我做的Flink(以及各种大数据框架笔记看图说话)XMind笔记我会在整理好之后上传到Github上,阅读量和点赞会直接影响更新速度,毕竟懒人都懂的。
项目需求