Created on 12-14-2017 10:29 AM - edited 09-16-2022 05:38 AM
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 )
Created 12-15-2017 11:03 AM
Question was answered on Stack Overflow.
Created 12-14-2017 04:21 PM
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.
Created 12-15-2017 11:03 AM
Question was answered on Stack Overflow.
Created 12-15-2017 01:09 PM
@Fabian Hueske
Need your help for below :
Created 12-15-2017 01:09 PM
@Fabian Hueske
Need your help for below :