Name: FLaNK: Low Code Streaming: Populating Kafka Topics with FlinkSQL Joins in Real-Time
Rating: 3.4 (9141 reviews)
Author: tspannhw

FLaNK: Low Code Streaming: Populating Kafka Topics with FlinkSQL Joins in Real-Time

FLaNK: Low Code Streaming: Populating Kafka Topics with FlinkSQL Joins in Real-Time

Then I can create my 3 tables. Two are the source ones to join and the third is the destination for my insert.

INSERT INTO global_sensor_events

SELECT

scada.uuid,

scada.systemtime ,

scada.temperaturef ,

scada.pressure ,

scada.humidity ,

scada.lux ,

scada.proximity ,

scada.oxidising ,

scada.reducing ,

scada.nh3 ,

scada.gasko,

energy.current,

energy.voltage ,

energy.power ,

energy.total,

energy.fanstatus

FROM energy,

 scada

WHERE

scada.systemtime = energy.systemtime;

Examples

Assets / Scripts / DDL / SQL

https://github.com/tspannhw/FlinkSQLDemo

Flink Guide to SQL Joins
https://www.youtube.com/watch?v=5AuBlVRKQuo

Slides

Article on Joins

https://www.datainmotion.dev/2020/05/flink-sql-preview.html

Resources