Hey Arran,
It seems that the preferred way, even in the Java API is to use a DDL
statement:
https://github.com/apache/flink/blob/master/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java#L602-L639
Hope this helps!
Best,
Rober
Hi,
I'm quite new to flink and I'm trying to create an application, which reads
ID's from a kinesis stream and then uses these to read from a mysql database. I
expect that I would just be doing a join of the id's onto the table
I'm struggling to understand from the documentation how to actually
