代码拉取完成,页面将自动刷新
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包下的东西都很重要(高级特性)
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。