如何根据 flink 中不同流中的事件处理已经可用的状态

问题描述

我们正在努力根据帐户上的活动得出帐户的状态。我们根据帐户上的用户活动计算并保留到期日期(即帐户到期的暂定未来日期)。

我们有一个手动日期更改事件,它提供了一个日期,根据该日期将帐户的状态发送为已过期。

我想知道实现这一目标的最佳方法是什么。 所以,我的问题是,与计算到期日期相比,日期更改事件是在未来发生的,广播状态可以解决这个问题吗?如果是,请建议方法。 或者,有没有像 Table API 这样更好的方法来解决这个问题?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)