question Flink Table Api how to connect with relational source? in Archives of Support Questions (Read Only)

Flink Table Api how to connect with relational source?

amit_dass — Fri, 16 Sep 2022 12:38:37 GMT

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 )

amit_dass — Fri, 15 Dec 2017 00:21:41 GMT

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.

fhueske — Fri, 15 Dec 2017 19:03:49 GMT

Question was answered on Stack Overflow.

amit_dass — Fri, 15 Dec 2017 21:09:30 GMT

@Fabian Hueske

Need your help for below :

amit_dass — Fri, 15 Dec 2017 21:09:50 GMT

@Fabian Hueske

Need your help for below :