apache-flink - Apache 弗林克 : How to query a relational database with the Table API?

Question

以下代码片段取自此 blog post :

val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ...

// register the table source
tEnv.registerTableSource("sensors", sensorTable)

我想从关系数据库中读取数据。 Flink 有用于 JDBC 数据库的 TableSource 吗？

Answer 1

在当前版本(1.4.0，2017 年 12 月)中，Flink 不提供内置的 TableSource 来从关系数据库中提取数据。

但是，有一个JDBCInputFormat可以使用。您可以

• 使用它通过 DataSet API 和 register the DataSet as a Table 从数据库读取数据或
• implement a JdbcTableSource包装JdbcInputFormat。 JdbcTableSource 的简单实现应该很容易实现。实现对并行读取、投影或过滤器下推的支持需要付出更多努力。