Apache Flink: Wie man eine relationale Datenbank mit der Tabellen-API abfragt?

Question

Der folgende Codeausschnitt wird aus diesem blog post genommen:

val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ... 

// register the table source 
tEnv.registerTableSource("sensors", sensorTable) 

Ich möchte Daten aus einer relationalen Datenbank lesen. Hat Flink eine TableSource für JDBC-Datenbanken?

Answer 1

In seiner aktuellen Version (1.4.0, Dez. 2017) bietet Flink kein eingebautes TableSource zum Einlesen von Daten aus einer relationalen Datenbank.

Es gibt jedoch eine JDBCInputFormat, die verwendet werden kann. Sie können entweder

• Verwendung es die Daten aus der Datenbank mit dem DataSet-API und register the DataSet as a Table oder
• implement a JdbcTableSource, dass die JdbcInputFormat Wraps zu lesen. Eine einfache Implementierung eines JdbcTableSource sollte einfach zu erreichen sein. Die Implementierung von Unterstützung für parallele Lesevorgänge, Projektion oder Filter-Push-Down erfordert mehr Aufwand.