以下代码段摘自该博客文章:
val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ...
// register the table source
tEnv.registerTableSource("sensors", sensorTable)
Run Code Online (Sandbox Code Playgroud)
我想从关系数据库中读取数据。Flink是否有TableSource用于JDBC数据库的?