小编Ami*_*ass的帖子

Apache Flink:如何使用Table API查询关系数据库?

以下代码段摘自该博客文章

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数据库的?

apache-flink flink-streaming flink-sql

2
推荐指数
1
解决办法
1067
查看次数

标签 统计

apache-flink ×1

flink-sql ×1

flink-streaming ×1