客户对使用CDC/kafka方法从数据库加载数据不感兴趣，而是要求使用调度程序方法。
有一个 fromCollection api 用于创建 DataStream，它接受从记录集合中加载数据。这对于一次性读取/加载效果很好，但不适用于计划场景。
有什么建议/参考/最佳遵循方法吗？
感谢Adv 文卡塔
有什么建议/参考/最佳遵循方法吗？
如果我理解正确的话，您想要一个定期从数据库加载数据的源吗？ 如果是这样，那么您可以使用 RichSourceFunction，并在 run 方法中定期获取数据并收集数据