scala - Apache Flink - 异步刷新 Hashmap

我正在使用 Scala API 开发一个 Apache Flink 应用程序（我是使用这项技术的新手）。

我正在使用哈希图来存储来自数据库的一些值，并且我需要每 1 小时刷新一次这些值。有什么方法可以异步刷新这个哈希图？

谢谢！

标签： scalaapache-flink

我不确定在 Flink 工作流的上下文中“异步刷新此哈希图”是什么意思。

对于它的价值，如果你有一个 hashmap，它由流经你的工作流的记录中的一些数据作为键，那么你可以使用 Flink 对托管键状态的支持来存储值（并检查它），并使其可查询。