在Apache Flink中,是否可以直接从数据库表中读取数据进行批处理,而不是从csv文件中读取数据



我需要我的Flink批处理作业来从我的Spring Boot项目的postgres数据库中读取数据。我在Flink中看到的选项仅用于读取csv文件。在这种情况下,我需要从我的表中创建一个csv文件。有什么解决方案吗?

如果你想从Postgres中读取数据(我想这个问题是关于这个的(,你可以使用Flink JDBC连接器,它将允许从包括Postgres在内的各种数据库中读取数据。你可以在这里找到更多信息。

相关内容

  • 没有找到相关文章

最新更新