Support Questions

Find answers, ask questions, and share your expertise

Flink Table Api how to connect with relational source?

avatar
Expert Contributor

Hi ,

I am referring "https://flink.apache.org/news/2017/04/04/dynamic-tables.html" in that database configuration is not shown

`val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ... // register the table source

tEnv.registerTableSource("sensors", sensorTable)

I have to connect with relational source, do Flink have API for database or JDBC approach we need to use ?

(Did we have any similar like for Apache Spark we have sqlcontext or sparksession object )

1 ACCEPTED SOLUTION

avatar
New Contributor
4 REPLIES 4

avatar
Expert Contributor

Adding this detail :

In its current version (1.4.0, Dec. 2017), Flink does not provide a built-in TableSource to ingest data from a relational database.

avatar
New Contributor

Question was answered on Stack Overflow.

avatar
Expert Contributor

avatar
Expert Contributor