1 Star 1 Fork 1

hanrentong/hflink1.12

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README
flink1.12版本学习
1.12版本真正实现了批流一体,DatasetApi已经被软弃用了(虽然能使用,但是已经过期)。

com.hrt.flink.action.DoubleElevenBigScreem 双十一大屏需求
    1.实时计算出当天零点截止到当前时间的销售总额 11月11日 00:00:00 ~ 23:59:59(怎么取到0点到当前的时间,也很牛逼,不是简单的滑动和滚动)
    2.计算出各个分类的销售top3(小顶堆排序很牛逼,求top的方法可以借鉴)
    3.每秒钟更新一次统计结果
com.hrt.flink.action.OrderAutomaticFavorableComments  订单自动好评的需求(很牛逼,用到了定时器设置超时以及状态管理)
com.hrt.flink.feature.BroadcastState1
     两个流的关联案例: 一个是数据流,一个是维度流,然后进行关联,由于维度流数据流小所以用broadcast,这里面可能会有关联不上的情况需要考虑(如果关联不上,就下一次关联了)。
                    毕竟两个流不可能实时同步
com.hrt.flink.feature包下的东西都很重要(高级特性)

空文件

简介

flink1.12版本java 展开 收起
Java
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Java
1
https://gitee.com/hanrentong/hflink1.12.git
[email protected]:hanrentong/hflink1.12.git
hanrentong
hflink1.12
hflink1.12
master

搜索帮助