首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

2021年大数据Flink(四十一):​​​​​​​Flink实现订单自动好评

---- Flink实现订单自动好评 需求 在电商领域会有这么一个场景,如果用户买了商品,在订单完成之后,一定时间之内没有做出评价,系统自动给与五星好评,我们今天主要使用Flink的定时器来简单实现这一功能...) * 我们今天主要使用Flink的定时器来简单实现这一功能。...* 注意: 这个需求不使用大数据的技术,就是用Web的定时器也可以做 * 课后可以用你熟悉的编程语言/工具/框架去实现 */ public class OrderAutomaticFavorite...,为了方便测试,设置5000ms/5s(实际中可以长一点) long interval = 5000L; //实现这个功能原本不需要分组,但是为了后面使用keyedState...ctx.timerService().registerProcessingTimeTimer(value.f2 + interval); } //实现定时器执行方法

67230
您找到你想要的搜索结果了吗?
是的
没有找到

Flink实战-定时器实现已完成订单自动五星好评

背景需求 在电商领域会有这么一个场景,如果用户买了商品,在订单完成之后,24小时之内没有做出评价,系统自动给与五星好评,我们今天主要使用flink的定时器来简单实现这一功能。...String,Long>,Object>{ private MapState mapState; //超过多长时间(interval,单位:毫秒) 没有评价,则自动五星好评...if (f){ //如果用户没有做评价,在调用相关的接口给与默认的五星评价 LOG.info("订单(orderid: {}) 超过 {} 毫秒未评价,调用接口给与五星自动好评...我们调用外部的接口来判断用户是否做过评价,如果没做评价,调用接口给与五星好评,如果做过评价,则什么也不处理,最后记得把相应的订单从MapState删除 完整的代码请参考 https://github.com

82330

扫码

添加站长 进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

    运营活动

    活动名称
    广告关闭
    领券