java - Flink Statefun Bootstrap 和状态过期
问题描述
根据此页面,我们可以在使用 Flink Statefun v2.1.0 时为状态设置 TTL。
根据此页面,我们还具有引导状态的能力。
第一个问题是,引导文档根本没有提到状态到期。对具有 TTL 的状态进行引导的正确方法是什么?有人可以给我举个例子吗?
第二个问题是,如果我在写入 1 天后将某个状态设置为过期,然后使用 6 个月的数据引导该状态,会发生什么情况?
整个引导状态是否会在 1 天后过期?
如果是这样,我该怎么做才能让它在 1 天过去后过期 1 天的数据?
解决方案
是的,如果这些数据在加载后没有被修改过,那么它会在一天后被删除。
每天过期一天的数据:在引导状态后,您可以向自己发送一条延迟消息,设置为一天后发送。当它到达时,删除最旧的数据并发送另一条延迟消息。
推荐阅读
- python - 使用“.get()”时的“参数‘self’未填充”
- python - 带有复选框的 QFileSystemModel
- macos - 在 MacOS 上的 SwiftUI 中查找点击位置
- javascript - 在 ReactJS 中的 Spotify API 上为 PKCE 身份验证创建代码验证器和质询
- c++ - C++ 中的类:无法将两个旧函数集成到“类格式”中
- java - Java 创建一个泛型类,该类实现另一个具有约束的泛型接口
- reactjs - 如何将数据从表单发送到另一个页面?
- python - 如何在 GUI-init 上初始化 Kivy TreeView?
- javascript - 错误时重新定位所需的属性
- excel - 如何在将 Excel 连接字符串连接到 SQL Server 分析服务时对其进行加密?