我正在编写一个 Flink 流程序，我需要用一些每 24 小时更新一次的数据（~10GB）来丰富 DataStream
如果是静态数据，我可以在流管道启动之前将其加载为键值状态，但如何每 24 小时更新一次？或者也许以某种方式在后台更新它？
创建一个自定义源（扩展 sourceFunction），每 24 小时提取一次数据