以下代码片段取自此博客文章：
val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ...
// register the table source
tEnv.registerTableSource("sensors", sensorTable)我想从关系数据库中读取数据。Flink有个朋友吗 TableSource 对于jdbc数据库？
以下代码片段取自此博客文章：
val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ...
// register the table source
tEnv.registerTableSource("sensors", sensorTable)我想从关系数据库中读取数据。Flink有个朋友吗 TableSource 对于jdbc数据库？
1条答案
按热度按时间hof1towb1#
在当前版本（1.4.0，2017年12月）中，flink不提供内置
TableSource从关系数据库中摄取数据。然而，有一个
JDBCInputFormat可以使用的。你也可以使用它可以使用dataset api从数据库中读取数据并注册
DataSet作为一个Table或者实施
JdbcTableSource那包裹着JdbcInputFormat. 一个简单的JdbcTableSource应该很容易实现。实现对并行读取、投影或过滤器下推的支持需要更多的工作。