Robin Moffatt • 3/10/2025

Data Wrangling with Flink SQL

This article details a hands-on project using Apache Flink SQL to ingest, unnest, and transform data from the UK Environment Agency's flood-monitoring API. It covers creating Flink tables from Kafka topics, handling nested JSON structures with CROSS JOIN UNNEST, and discusses considerations for schema evolution and efficient data pipeline design in a streaming context.

0 comments

#sql #Kafka #Apache Flink