Flink如何处理跨State生命周期数据?

通过flink我们可以基于某个订单表实时统计售卖的订单金额。但是如果订单变动会跨Flink的生命周期要如何处理?

具体而言,订单ID 1 是一个金额为100的明细数据,在它刚创建的时候,我统计了该条明细的金额。但是如果在该明细创建过了一个月,这个明细的非金额字段发生了变化(比如某个状态字段),使得这条数据又进入了Flink,State中又没有该明细的历史数据,导致我把该数据又算了一边。由于State生命周期又不能无限制的扩大,请问有什么好方法可以处理这种问题么?

全部评论
点赞 回复 分享
发布于 2023-11-22 17:49 广东

相关推荐

渐好:软光栅真的写明白了吗,既然是软渲那技术栈不应该使用OpenGL,光追和bvh既不算什么高级渲染技术更不应该属于软渲的内容,git那个项目没啥用,建议把前两个项目重新组织一下语言,比如软渲染那个项目 冯着色和msaa、贴图这几项分开写,写的到位点,如果你还学过光追那就单独写出来,如果没把握考官问你答不上来就别写给自己找麻烦,在技术栈那一栏简单提一下自己学过就行,这样杂的放在一起不太严谨,个人愚见.
点赞 评论 收藏
分享
三题看不懂四题不明白二题无法AC T=int(input()) for _ in range(T): n=int(input()) s=input().split() k,mx=1,1 for i in range(len(s)-1): if len(s[i])<len(s[i+1]): k+=1 elif len(s[i])==len(s[i+1]): if s[i]<=s[i+1]: k+=1 ...
恭喜臭臭猴子:第二题用栈就行。合法的括号直接出栈了,剩下的是不合法的,肯定都得一个一个走。出入栈的过程中得记下进栈的括号的下标。最后栈里剩下的括号如果相邻两个的下标不连续,说明它们中间有一个合法的括号序列被出栈,结果加一
投递拼多多集团-PDD等公司10个岗位 > 拼多多求职进展汇总 笔试
点赞 评论 收藏
分享
评论
点赞
收藏
分享

创作者周榜

更多
牛客网
牛客企业服务