是否可以直接从数据库 table 读取数据以在 Apache Flink 中进行批处理而不是从 csv 文件读取？
Is it possible to read data directly from a database table for batch processing in Apache Flink than reading from a csv file?
我需要我的 Flink 批处理作业从我的 Spring Boot 项目的 postgres 数据库中读取数据。我在 Flink 中看到的选项仅用于读取 csv 文件。在这种情况下，我需要从我的 table 创建一个 csv 文件。有什么解决办法吗？
如果您想从 Postgres 读取数据（我假设这个问题是关于它的）您可以使用 Flink JDBC 连接器，它将允许从包括 Postgres 在内的各种数据库读取数据。您可以找到更多信息 here.
我需要我的 Flink 批处理作业从我的 Spring Boot 项目的 postgres 数据库中读取数据。我在 Flink 中看到的选项仅用于读取 csv 文件。在这种情况下，我需要从我的 table 创建一个 csv 文件。有什么解决办法吗？
如果您想从 Postgres 读取数据（我假设这个问题是关于它的）您可以使用 Flink JDBC 连接器，它将允许从包括 Postgres 在内的各种数据库读取数据。您可以找到更多信息 here.